@@ -166,7 +166,7 @@ exports._takeVar = function (left, right, avar, cb) {
166
166
runEff ( cb ( left ( avar . error ) ) ) ;
167
167
return NO_EFFECT ;
168
168
}
169
- var cell = putLast ( avar . takes , { cb : cb , read : false } ) ;
169
+ var cell = putLast ( avar . takes , cb ) ;
170
170
drainVar ( left , right , avar ) ;
171
171
return function ( ) {
172
172
deleteCell ( cell ) ;
@@ -180,7 +180,7 @@ exports._readVar = function (left, right, avar, cb) {
180
180
runEff ( cb ( left ( avar . error ) ) ) ;
181
181
return NO_EFFECT ;
182
182
}
183
- var cell = putLast ( avar . reads , { cb : cb , read : true } ) ;
183
+ var cell = putLast ( avar . reads , cb ) ;
184
184
drainVar ( left , right , avar ) ;
185
185
return function ( ) {
186
186
deleteCell ( cell ) ;
@@ -263,11 +263,11 @@ function drainVar (left, right, avar) {
263
263
}
264
264
265
265
while ( r = takeHead ( rs ) ) {
266
- runEff ( r . cb ( value ) ) ;
266
+ runEff ( r ( value ) ) ;
267
267
}
268
268
269
269
if ( t = takeHead ( ts ) ) {
270
- runEff ( t . cb ( value ) ) ;
270
+ runEff ( t ( value ) ) ;
271
271
}
272
272
}
273
273
break ;
@@ -287,11 +287,11 @@ function drainVar (left, right, avar) {
287
287
// We only want to process the reads queued up before running these
288
288
// callbacks so we guard on rsize.
289
289
while ( rsize -- && ( r = takeHead ( rs ) ) ) {
290
- runEff ( r . cb ( right ( value ) ) ) ;
290
+ runEff ( r ( right ( value ) ) ) ;
291
291
}
292
292
if ( t !== null ) {
293
293
avar . value = EMPTY ;
294
- runEff ( t . cb ( right ( value ) ) ) ;
294
+ runEff ( t ( right ( value ) ) ) ;
295
295
}
296
296
}
297
297
0 commit comments