File tree Expand file tree Collapse file tree 2 files changed +12
-10
lines changed Expand file tree Collapse file tree 2 files changed +12
-10
lines changed Original file line number Diff line number Diff line change 33var csp = require ( '../../dist/index' ) ;
44
55
6- var source = function * ( start ) {
7- for ( var i = 1 ; ; ++ i )
8- yield ( i ) ;
9- } ;
10-
116var writeThings = function ( ch ) {
12- csp . pipe ( csp . fromGenerator ( source ( 1 ) ) , ch ) ;
7+ var data = csp . generate ( function * ( ) {
8+ for ( var i = 1 ; ; ++ i )
9+ yield ( i ) ;
10+ } ) ;
11+
12+ csp . pipe ( data , ch ) ;
1313} ;
1414
1515var readThings = function ( ch ) {
Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ exports.createLock = function() {
6565} ;
6666
6767
68- exports . iterator = function ( next ) {
68+ exports . iterate = function ( next ) {
6969 var _closed = false ;
7070
7171 return {
@@ -89,9 +89,11 @@ exports.iterator = function(next) {
8989} ;
9090
9191
92- exports . fromGenerator = function ( gen ) {
93- return exports . iterator ( function ( ) {
94- var step = gen . next ( ) ;
92+ exports . generate = function ( genFn ) {
93+ var _gen = genFn ( ) ;
94+
95+ return exports . iterate ( function ( ) {
96+ var step = _gen . next ( ) ;
9597 return step . done ? undefined : step . value ;
9698 } ) ;
9799} ;
You can’t perform that action at this time.
0 commit comments