@@ -166,7 +166,7 @@ exports._takeVar = function (left, right, avar, cb) {
166166 runEff ( cb ( left ( avar . error ) ) ) ;
167167 return NO_EFFECT ;
168168 }
169- var cell = putLast ( avar . takes , { cb : cb , read : false } ) ;
169+ var cell = putLast ( avar . takes , cb ) ;
170170 drainVar ( left , right , avar ) ;
171171 return function ( ) {
172172 deleteCell ( cell ) ;
@@ -180,7 +180,7 @@ exports._readVar = function (left, right, avar, cb) {
180180 runEff ( cb ( left ( avar . error ) ) ) ;
181181 return NO_EFFECT ;
182182 }
183- var cell = putLast ( avar . reads , { cb : cb , read : true } ) ;
183+ var cell = putLast ( avar . reads , cb ) ;
184184 drainVar ( left , right , avar ) ;
185185 return function ( ) {
186186 deleteCell ( cell ) ;
@@ -263,11 +263,11 @@ function drainVar (left, right, avar) {
263263 }
264264
265265 while ( r = takeHead ( rs ) ) {
266- runEff ( r . cb ( value ) ) ;
266+ runEff ( r ( value ) ) ;
267267 }
268268
269269 if ( t = takeHead ( ts ) ) {
270- runEff ( t . cb ( value ) ) ;
270+ runEff ( t ( value ) ) ;
271271 }
272272 }
273273 break ;
@@ -287,11 +287,11 @@ function drainVar (left, right, avar) {
287287 // We only want to process the reads queued up before running these
288288 // callbacks so we guard on rsize.
289289 while ( rsize -- && ( r = takeHead ( rs ) ) ) {
290- runEff ( r . cb ( right ( value ) ) ) ;
290+ runEff ( r ( right ( value ) ) ) ;
291291 }
292292 if ( t !== null ) {
293293 avar . value = EMPTY ;
294- runEff ( t . cb ( right ( value ) ) ) ;
294+ runEff ( t ( right ( value ) ) ) ;
295295 }
296296 }
297297
0 commit comments