@@ -651,9 +651,9 @@ dart_library.library('dart/async', null, /* Imports */[
651
651
return ;
652
652
}
653
653
elementIndex = dart . notNull ( elementIndex ) + 1 ;
654
- } , dart . dynamic , [ T ] ) , { onError : dart . bind ( future , _completeError ) , onDone : dart . fn ( ( ) => {
654
+ } , dart . dynamic , [ T ] ) , { onError : dart . bind ( future , _completeError ) , onDone : dart . fn ( ( ( ) => {
655
655
future [ _completeError ] ( core . RangeError . index ( index , this , "index" , null , elementIndex ) ) ;
656
- } ) , cancelOnError : true } ) ;
656
+ } ) . bind ( this ) ) , cancelOnError : true } ) ;
657
657
return future ;
658
658
}
659
659
timeout ( timeLimit , opts ) {
@@ -980,10 +980,10 @@ dart_library.library('dart/async', null, /* Imports */[
980
980
this [ _onDone ] = dart . fn ( ( ) => {
981
981
result [ _complete ] ( futureValue ) ;
982
982
} ) ;
983
- this [ _onError ] = dart . fn ( ( error , stackTrace ) => {
983
+ this [ _onError ] = dart . fn ( ( ( error , stackTrace ) => {
984
984
this . cancel ( ) ;
985
985
result [ _completeError ] ( error , dart . as ( stackTrace , core . StackTrace ) ) ;
986
- } ) ;
986
+ } ) . bind ( this ) ) ;
987
987
return result ;
988
988
}
989
989
get [ _isInputPaused ] ( ) {
@@ -2336,9 +2336,9 @@ dart_library.library('dart/async', null, /* Imports */[
2336
2336
[ _addListener ] ( listener ) {
2337
2337
dart . assert ( listener [ _nextListener ] == null ) ;
2338
2338
if ( dart . notNull ( this [ _isComplete ] ) ) {
2339
- this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ) => {
2339
+ this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ( ) => {
2340
2340
_Future$ ( ) . _propagateToListeners ( this , listener ) ;
2341
- } ) ) ;
2341
+ } ) . bind ( this ) ) ) ;
2342
2342
} else {
2343
2343
listener [ _nextListener ] = dart . as ( this [ _resultOrListeners ] , _FutureListener ) ;
2344
2344
this [ _resultOrListeners ] = listener ;
@@ -2420,9 +2420,9 @@ dart_library.library('dart/async', null, /* Imports */[
2420
2420
let coreFuture = dart . as ( typedFuture , _Future$ ( T ) ) ;
2421
2421
if ( dart . notNull ( coreFuture [ _isComplete ] ) && dart . notNull ( coreFuture [ _hasError ] ) ) {
2422
2422
this [ _markPendingCompletion ] ( ) ;
2423
- this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ) => {
2423
+ this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ( ) => {
2424
2424
_Future$ ( ) . _chainCoreFuture ( coreFuture , this ) ;
2425
- } ) ) ;
2425
+ } ) . bind ( this ) ) ) ;
2426
2426
} else {
2427
2427
_Future$ ( ) . _chainCoreFuture ( coreFuture , this ) ;
2428
2428
}
@@ -2434,16 +2434,16 @@ dart_library.library('dart/async', null, /* Imports */[
2434
2434
let typedValue = dart . as ( value , T ) ;
2435
2435
}
2436
2436
this [ _markPendingCompletion ] ( ) ;
2437
- this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ) => {
2437
+ this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ( ) => {
2438
2438
this [ _completeWithValue ] ( value ) ;
2439
- } ) ) ;
2439
+ } ) . bind ( this ) ) ) ;
2440
2440
}
2441
2441
[ _asyncCompleteError ] ( error , stackTrace ) {
2442
2442
dart . assert ( ! dart . notNull ( this [ _isComplete ] ) ) ;
2443
2443
this [ _markPendingCompletion ] ( ) ;
2444
- this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ) => {
2444
+ this [ _zone ] . scheduleMicrotask ( dart . fn ( ( ( ) => {
2445
2445
this [ _completeError ] ( error , stackTrace ) ;
2446
- } ) ) ;
2446
+ } ) . bind ( this ) ) ) ;
2447
2447
}
2448
2448
static _propagateToListeners ( source , listeners ) {
2449
2449
while ( true ) {
@@ -3185,9 +3185,9 @@ dart_library.library('dart/async', null, /* Imports */[
3185
3185
this [ _varData ] = subscription ;
3186
3186
}
3187
3187
subscription [ _setPendingEvents ] ( pendingEvents ) ;
3188
- subscription [ _guardCallback ] ( dart . fn ( ( ) => {
3188
+ subscription [ _guardCallback ] ( dart . fn ( ( ( ) => {
3189
3189
_runGuarded ( this [ _onListen ] ) ;
3190
- } ) ) ;
3190
+ } ) . bind ( this ) ) ) ;
3191
3191
return dart . as ( subscription , StreamSubscription$ ( T ) ) ;
3192
3192
}
3193
3193
[ _recordCancel ] ( subscription ) {
@@ -3457,9 +3457,9 @@ dart_library.library('dart/async', null, /* Imports */[
3457
3457
this . addStreamFuture [ _asyncComplete ] ( null ) ;
3458
3458
return null ;
3459
3459
}
3460
- return cancel . whenComplete ( dart . fn ( ( ) => {
3460
+ return cancel . whenComplete ( dart . fn ( ( ( ) => {
3461
3461
this . addStreamFuture [ _asyncComplete ] ( null ) ;
3462
- } ) ) ;
3462
+ } ) . bind ( this ) ) ) ;
3463
3463
}
3464
3464
complete ( ) {
3465
3465
this . addStreamFuture [ _asyncComplete ] ( null ) ;
@@ -3532,7 +3532,7 @@ dart_library.library('dart/async', null, /* Imports */[
3532
3532
let _ = new _BufferingStreamSubscription ( onData , onError , onDone , cancelOnError ) ;
3533
3533
_ [ _setPendingEvents ] ( this [ _pending ] ( ) ) ;
3534
3534
return _ ;
3535
- } ) ( ) , StreamSubscription$ ( T ) ) ;
3535
+ } ) . bind ( this ) ( ) , StreamSubscription$ ( T ) ) ;
3536
3536
}
3537
3537
}
3538
3538
dart . setSignature ( _GeneratedStreamImpl , {
@@ -3562,13 +3562,13 @@ dart_library.library('dart/async', null, /* Imports */[
3562
3562
this [ _state ] = _PendingEvents . _STATE_SCHEDULED ;
3563
3563
return ;
3564
3564
}
3565
- scheduleMicrotask ( dart . fn ( ( ) => {
3565
+ scheduleMicrotask ( dart . fn ( ( ( ) => {
3566
3566
let oldState = this [ _state ] ;
3567
3567
this [ _state ] = _PendingEvents . _STATE_UNSCHEDULED ;
3568
3568
if ( oldState == _PendingEvents . _STATE_CANCELED )
3569
3569
return ;
3570
3570
this . handleNext ( dispatch ) ;
3571
- } ) ) ;
3571
+ } ) . bind ( this ) ) ) ;
3572
3572
this [ _state ] = _PendingEvents . _STATE_SCHEDULED ;
3573
3573
}
3574
3574
cancelSchedule ( ) {
@@ -5253,25 +5253,25 @@ dart_library.library('dart/async', null, /* Imports */[
5253
5253
bindCallback ( f , opts ) {
5254
5254
let runGuarded = opts && 'runGuarded' in opts ? opts . runGuarded : true ;
5255
5255
if ( dart . notNull ( runGuarded ) ) {
5256
- return dart . fn ( ( ) => this . runGuarded ( f ) ) ;
5256
+ return dart . fn ( ( ( ) => this . runGuarded ( f ) ) . bind ( this ) ) ;
5257
5257
} else {
5258
- return dart . fn ( ( ) => this . run ( f ) ) ;
5258
+ return dart . fn ( ( ( ) => this . run ( f ) ) . bind ( this ) ) ;
5259
5259
}
5260
5260
}
5261
5261
bindUnaryCallback ( f , opts ) {
5262
5262
let runGuarded = opts && 'runGuarded' in opts ? opts . runGuarded : true ;
5263
5263
if ( dart . notNull ( runGuarded ) ) {
5264
- return dart . fn ( arg => this . runUnaryGuarded ( f , arg ) ) ;
5264
+ return dart . fn ( ( arg => this . runUnaryGuarded ( f , arg ) ) . bind ( this ) ) ;
5265
5265
} else {
5266
- return dart . fn ( arg => this . runUnary ( f , arg ) ) ;
5266
+ return dart . fn ( ( arg => this . runUnary ( f , arg ) ) . bind ( this ) ) ;
5267
5267
}
5268
5268
}
5269
5269
bindBinaryCallback ( f , opts ) {
5270
5270
let runGuarded = opts && 'runGuarded' in opts ? opts . runGuarded : true ;
5271
5271
if ( dart . notNull ( runGuarded ) ) {
5272
- return dart . fn ( ( arg1 , arg2 ) => this . runBinaryGuarded ( f , arg1 , arg2 ) ) ;
5272
+ return dart . fn ( ( ( arg1 , arg2 ) => this . runBinaryGuarded ( f , arg1 , arg2 ) ) . bind ( this ) ) ;
5273
5273
} else {
5274
- return dart . fn ( ( arg1 , arg2 ) => this . runBinary ( f , arg1 , arg2 ) ) ;
5274
+ return dart . fn ( ( ( arg1 , arg2 ) => this . runBinary ( f , arg1 , arg2 ) ) . bind ( this ) ) ;
5275
5275
}
5276
5276
}
5277
5277
get ( key ) {
@@ -5525,27 +5525,27 @@ dart_library.library('dart/async', null, /* Imports */[
5525
5525
let runGuarded = opts && 'runGuarded' in opts ? opts . runGuarded : true ;
5526
5526
let registered = this . registerCallback ( f ) ;
5527
5527
if ( dart . notNull ( runGuarded ) ) {
5528
- return dart . fn ( ( ) => this . runGuarded ( registered ) ) ;
5528
+ return dart . fn ( ( ( ) => this . runGuarded ( registered ) ) . bind ( this ) ) ;
5529
5529
} else {
5530
- return dart . fn ( ( ) => this . run ( registered ) ) ;
5530
+ return dart . fn ( ( ( ) => this . run ( registered ) ) . bind ( this ) ) ;
5531
5531
}
5532
5532
}
5533
5533
bindUnaryCallback ( f , opts ) {
5534
5534
let runGuarded = opts && 'runGuarded' in opts ? opts . runGuarded : true ;
5535
5535
let registered = this . registerUnaryCallback ( f ) ;
5536
5536
if ( dart . notNull ( runGuarded ) ) {
5537
- return dart . fn ( arg => this . runUnaryGuarded ( registered , arg ) ) ;
5537
+ return dart . fn ( ( arg => this . runUnaryGuarded ( registered , arg ) ) . bind ( this ) ) ;
5538
5538
} else {
5539
- return dart . fn ( arg => this . runUnary ( registered , arg ) ) ;
5539
+ return dart . fn ( ( arg => this . runUnary ( registered , arg ) ) . bind ( this ) ) ;
5540
5540
}
5541
5541
}
5542
5542
bindBinaryCallback ( f , opts ) {
5543
5543
let runGuarded = opts && 'runGuarded' in opts ? opts . runGuarded : true ;
5544
5544
let registered = this . registerBinaryCallback ( f ) ;
5545
5545
if ( dart . notNull ( runGuarded ) ) {
5546
- return dart . fn ( ( arg1 , arg2 ) => this . runBinaryGuarded ( registered , arg1 , arg2 ) ) ;
5546
+ return dart . fn ( ( ( arg1 , arg2 ) => this . runBinaryGuarded ( registered , arg1 , arg2 ) ) . bind ( this ) ) ;
5547
5547
} else {
5548
- return dart . fn ( ( arg1 , arg2 ) => this . runBinary ( registered , arg1 , arg2 ) ) ;
5548
+ return dart . fn ( ( ( arg1 , arg2 ) => this . runBinary ( registered , arg1 , arg2 ) ) . bind ( this ) ) ;
5549
5549
}
5550
5550
}
5551
5551
get ( key ) {
0 commit comments