File tree 3 files changed +15
-18
lines changed
3 files changed +15
-18
lines changed Original file line number Diff line number Diff line change @@ -95,22 +95,19 @@ exports.stream = function (em, eventName) {
95
95
next ( ) ;
96
96
} ;
97
97
98
- self . loop = function loop ( cb ) {
98
+ self . loop = function ( cb ) {
99
99
var end = false ;
100
100
101
- var s = Chainsaw . saw ( builder , { } ) ;
102
- s . on ( 'end' , function ( ) {
103
- if ( ! end ) self . loop ( cb )
104
- } ) ;
105
-
106
- var r = builder . call ( s . handlers , s ) ;
107
- if ( r !== undefined ) s . handlers = r ;
108
-
109
- var ch = s . chain ( ) ;
110
- ch . vars = vars . store ;
111
- cb . call ( ch , function ( ) {
112
- end = true ;
113
- next ( ) ;
101
+ saw . nest ( false , function loop ( ) {
102
+ this . vars = vars . store ;
103
+ cb . call ( this , function ( ) {
104
+ end = true ;
105
+ next ( ) ;
106
+ } , vars . store ) ;
107
+ this . tap ( function ( ) {
108
+ if ( end ) saw . next ( )
109
+ else loop . call ( this )
110
+ } ) ;
114
111
} , vars . store ) ;
115
112
} ;
116
113
Original file line number Diff line number Diff line change 21
21
"url" : " http://substack.net"
22
22
},
23
23
"dependencies" : {
24
- "chainsaw" : " >=0.0.4 " ,
24
+ "chainsaw" : " >=0.0.7 " ,
25
25
"put" : " >=0.0.1" ,
26
26
"buffers" : " >=0.0.1"
27
27
},
Original file line number Diff line number Diff line change @@ -360,13 +360,13 @@ exports.loop = function () {
360
360
} , 500 ) ;
361
361
362
362
Binary . stream ( em )
363
- . loop ( function ( end ) {
364
- var vars_ = this . vars ;
363
+ . loop ( function ( end , vars ) {
364
+ assert . ok ( vars === this . vars ) ;
365
365
this
366
366
. word16lu ( 'a' )
367
367
. word8u ( 'b' )
368
368
. word8s ( 'c' )
369
- . tap ( function ( vars ) {
369
+ . tap ( function ( vars_ ) {
370
370
assert . ok ( vars === vars_ ) ;
371
371
times ++ ;
372
372
if ( vars . c < 0 ) end ( ) ;
You can’t perform that action at this time.
0 commit comments