| OLD | NEW |
| 1 dart_library.library('dart/async', null, /* Imports */[ | 1 dart_library.library('dart/async', null, /* Imports */[ |
| 2 'dart/_runtime', | 2 'dart/_runtime', |
| 3 'dart/core', | 3 'dart/core', |
| 4 'dart/_internal', | 4 'dart/_internal', |
| 5 'dart/collection' | 5 'dart/collection' |
| 6 ], /* Lazy imports */[ | 6 ], /* Lazy imports */[ |
| 7 'dart/_isolate_helper' | 7 'dart/_isolate_helper' |
| 8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { | 8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { |
| 9 'use strict'; | 9 'use strict'; |
| 10 let dartx = dart.dartx; | 10 let dartx = dart.dartx; |
| (...skipping 624 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 635 let future = new (_Future$(T))(); | 635 let future = new (_Future$(T))(); |
| 636 let subscription = null; | 636 let subscription = null; |
| 637 let elementIndex = 0; | 637 let elementIndex = 0; |
| 638 subscription = this.listen(dart.fn(value => { | 638 subscription = this.listen(dart.fn(value => { |
| 639 dart.as(value, T); | 639 dart.as(value, T); |
| 640 if (index == elementIndex) { | 640 if (index == elementIndex) { |
| 641 _cancelAndValue(subscription, future, value); | 641 _cancelAndValue(subscription, future, value); |
| 642 return; | 642 return; |
| 643 } | 643 } |
| 644 elementIndex = elementIndex + 1; | 644 elementIndex = elementIndex + 1; |
| 645 }, dart.void, [T]), {onError: dart.bind(future, _completeError), onDone:
dart.fn((() => { | 645 }, dart.void, [T]), {onError: dart.bind(future, _completeError), onDone:
dart.fn(() => { |
| 646 future[_completeError](core.RangeError.index(index, this, "index", n
ull, elementIndex)); | 646 future[_completeError](core.RangeError.index(index, this, "index", n
ull, elementIndex)); |
| 647 }).bind(this), dart.void, []), cancelOnError: true}); | 647 }, dart.void, []), cancelOnError: true}); |
| 648 return future; | 648 return future; |
| 649 } | 649 } |
| 650 timeout(timeLimit, opts) { | 650 timeout(timeLimit, opts) { |
| 651 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; | 651 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; |
| 652 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); | 652 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); |
| 653 let controller = null; | 653 let controller = null; |
| 654 let subscription = null; | 654 let subscription = null; |
| 655 let timer = null; | 655 let timer = null; |
| 656 let zone = null; | 656 let zone = null; |
| 657 let timeout2 = null; | 657 let timeout2 = null; |
| (...skipping 291 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 949 if (dart.notNull(this[_isCanceled])) return this[_cancelFuture]; | 949 if (dart.notNull(this[_isCanceled])) return this[_cancelFuture]; |
| 950 this[_cancel](); | 950 this[_cancel](); |
| 951 return this[_cancelFuture]; | 951 return this[_cancelFuture]; |
| 952 } | 952 } |
| 953 asFuture(futureValue) { | 953 asFuture(futureValue) { |
| 954 if (futureValue === void 0) futureValue = null; | 954 if (futureValue === void 0) futureValue = null; |
| 955 let result = new (_Future$(T))(); | 955 let result = new (_Future$(T))(); |
| 956 this[_onDone] = dart.fn(() => { | 956 this[_onDone] = dart.fn(() => { |
| 957 result[_complete](futureValue); | 957 result[_complete](futureValue); |
| 958 }, dart.void, []); | 958 }, dart.void, []); |
| 959 this[_onError] = dart.fn(((error, stackTrace) => { | 959 this[_onError] = dart.fn((error, stackTrace) => { |
| 960 this.cancel(); | 960 this.cancel(); |
| 961 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 961 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
| 962 }).bind(this)); | 962 }); |
| 963 return result; | 963 return result; |
| 964 } | 964 } |
| 965 get [_isInputPaused]() { | 965 get [_isInputPaused]() { |
| 966 return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscr
iption$()._STATE_INPUT_PAUSED)) != 0; | 966 return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscr
iption$()._STATE_INPUT_PAUSED)) != 0; |
| 967 } | 967 } |
| 968 get [_isClosed]() { | 968 get [_isClosed]() { |
| 969 return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscr
iption$()._STATE_CLOSED)) != 0; | 969 return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscr
iption$()._STATE_CLOSED)) != 0; |
| 970 } | 970 } |
| 971 get [_isCanceled]() { | 971 get [_isCanceled]() { |
| 972 return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscr
iption$()._STATE_CANCELED)) != 0; | 972 return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscr
iption$()._STATE_CANCELED)) != 0; |
| (...skipping 1305 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2278 dart.assert(!dart.notNull(this[_isComplete])); | 2278 dart.assert(!dart.notNull(this[_isComplete])); |
| 2279 this[_state] = _Future$()._ERROR; | 2279 this[_state] = _Future$()._ERROR; |
| 2280 this[_resultOrListeners] = error; | 2280 this[_resultOrListeners] = error; |
| 2281 } | 2281 } |
| 2282 [_setError](error, stackTrace) { | 2282 [_setError](error, stackTrace) { |
| 2283 this[_setErrorObject](new AsyncError(error, stackTrace)); | 2283 this[_setErrorObject](new AsyncError(error, stackTrace)); |
| 2284 } | 2284 } |
| 2285 [_addListener](listener) { | 2285 [_addListener](listener) { |
| 2286 dart.assert(listener[_nextListener] == null); | 2286 dart.assert(listener[_nextListener] == null); |
| 2287 if (dart.notNull(this[_isComplete])) { | 2287 if (dart.notNull(this[_isComplete])) { |
| 2288 this[_zone].scheduleMicrotask(dart.fn((() => { | 2288 this[_zone].scheduleMicrotask(dart.fn(() => { |
| 2289 _Future$()._propagateToListeners(this, listener); | 2289 _Future$()._propagateToListeners(this, listener); |
| 2290 }).bind(this), dart.void, [])); | 2290 }, dart.void, [])); |
| 2291 } else { | 2291 } else { |
| 2292 listener[_nextListener] = dart.as(this[_resultOrListeners], _FutureLis
tener); | 2292 listener[_nextListener] = dart.as(this[_resultOrListeners], _FutureLis
tener); |
| 2293 this[_resultOrListeners] = listener; | 2293 this[_resultOrListeners] = listener; |
| 2294 } | 2294 } |
| 2295 } | 2295 } |
| 2296 [_removeListeners]() { | 2296 [_removeListeners]() { |
| 2297 dart.assert(!dart.notNull(this[_isComplete])); | 2297 dart.assert(!dart.notNull(this[_isComplete])); |
| 2298 let current = dart.as(this[_resultOrListeners], _FutureListener); | 2298 let current = dart.as(this[_resultOrListeners], _FutureListener); |
| 2299 this[_resultOrListeners] = null; | 2299 this[_resultOrListeners] = null; |
| 2300 let prev = null; | 2300 let prev = null; |
| (...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2360 } | 2360 } |
| 2361 [_asyncComplete](value) { | 2361 [_asyncComplete](value) { |
| 2362 dart.assert(!dart.notNull(this[_isComplete])); | 2362 dart.assert(!dart.notNull(this[_isComplete])); |
| 2363 if (value == null) { | 2363 if (value == null) { |
| 2364 } else if (dart.is(value, Future)) { | 2364 } else if (dart.is(value, Future)) { |
| 2365 let typedFuture = dart.as(value, Future$(T)); | 2365 let typedFuture = dart.as(value, Future$(T)); |
| 2366 if (dart.is(typedFuture, _Future$())) { | 2366 if (dart.is(typedFuture, _Future$())) { |
| 2367 let coreFuture = dart.as(typedFuture, _Future$(T)); | 2367 let coreFuture = dart.as(typedFuture, _Future$(T)); |
| 2368 if (dart.notNull(coreFuture[_isComplete]) && dart.notNull(coreFuture
[_hasError])) { | 2368 if (dart.notNull(coreFuture[_isComplete]) && dart.notNull(coreFuture
[_hasError])) { |
| 2369 this[_markPendingCompletion](); | 2369 this[_markPendingCompletion](); |
| 2370 this[_zone].scheduleMicrotask(dart.fn((() => { | 2370 this[_zone].scheduleMicrotask(dart.fn(() => { |
| 2371 _Future$()._chainCoreFuture(coreFuture, this); | 2371 _Future$()._chainCoreFuture(coreFuture, this); |
| 2372 }).bind(this), dart.void, [])); | 2372 }, dart.void, [])); |
| 2373 } else { | 2373 } else { |
| 2374 _Future$()._chainCoreFuture(coreFuture, this); | 2374 _Future$()._chainCoreFuture(coreFuture, this); |
| 2375 } | 2375 } |
| 2376 } else { | 2376 } else { |
| 2377 _Future$()._chainForeignFuture(typedFuture, this); | 2377 _Future$()._chainForeignFuture(typedFuture, this); |
| 2378 } | 2378 } |
| 2379 return; | 2379 return; |
| 2380 } else { | 2380 } else { |
| 2381 let typedValue = dart.as(value, T); | 2381 let typedValue = dart.as(value, T); |
| 2382 } | 2382 } |
| 2383 this[_markPendingCompletion](); | 2383 this[_markPendingCompletion](); |
| 2384 this[_zone].scheduleMicrotask(dart.fn((() => { | 2384 this[_zone].scheduleMicrotask(dart.fn(() => { |
| 2385 this[_completeWithValue](value); | 2385 this[_completeWithValue](value); |
| 2386 }).bind(this), dart.void, [])); | 2386 }, dart.void, [])); |
| 2387 } | 2387 } |
| 2388 [_asyncCompleteError](error, stackTrace) { | 2388 [_asyncCompleteError](error, stackTrace) { |
| 2389 dart.assert(!dart.notNull(this[_isComplete])); | 2389 dart.assert(!dart.notNull(this[_isComplete])); |
| 2390 this[_markPendingCompletion](); | 2390 this[_markPendingCompletion](); |
| 2391 this[_zone].scheduleMicrotask(dart.fn((() => { | 2391 this[_zone].scheduleMicrotask(dart.fn(() => { |
| 2392 this[_completeError](error, stackTrace); | 2392 this[_completeError](error, stackTrace); |
| 2393 }).bind(this), dart.void, [])); | 2393 }, dart.void, [])); |
| 2394 } | 2394 } |
| 2395 static _propagateToListeners(source, listeners) { | 2395 static _propagateToListeners(source, listeners) { |
| 2396 while (true) { | 2396 while (true) { |
| 2397 dart.assert(source[_isComplete]); | 2397 dart.assert(source[_isComplete]); |
| 2398 let hasError = source[_hasError]; | 2398 let hasError = source[_hasError]; |
| 2399 if (listeners == null) { | 2399 if (listeners == null) { |
| 2400 if (dart.notNull(hasError)) { | 2400 if (dart.notNull(hasError)) { |
| 2401 let asyncError = source[_error]; | 2401 let asyncError = source[_error]; |
| 2402 source[_zone].handleUncaughtError(asyncError.error, asyncError.sta
ckTrace); | 2402 source[_zone].handleUncaughtError(asyncError.error, asyncError.sta
ckTrace); |
| 2403 } | 2403 } |
| (...skipping 706 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3110 let pendingEvents = this[_pendingEvents]; | 3110 let pendingEvents = this[_pendingEvents]; |
| 3111 this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamControll
er$()._STATE_SUBSCRIBED); | 3111 this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamControll
er$()._STATE_SUBSCRIBED); |
| 3112 if (dart.notNull(this[_isAddingStream])) { | 3112 if (dart.notNull(this[_isAddingStream])) { |
| 3113 let addState = dart.as(this[_varData], _StreamControllerAddStreamState
); | 3113 let addState = dart.as(this[_varData], _StreamControllerAddStreamState
); |
| 3114 addState.varData = subscription; | 3114 addState.varData = subscription; |
| 3115 addState.resume(); | 3115 addState.resume(); |
| 3116 } else { | 3116 } else { |
| 3117 this[_varData] = subscription; | 3117 this[_varData] = subscription; |
| 3118 } | 3118 } |
| 3119 subscription[_setPendingEvents](pendingEvents); | 3119 subscription[_setPendingEvents](pendingEvents); |
| 3120 subscription[_guardCallback](dart.fn((() => { | 3120 subscription[_guardCallback](dart.fn(() => { |
| 3121 _runGuarded(this[_onListen]); | 3121 _runGuarded(this[_onListen]); |
| 3122 }).bind(this))); | 3122 })); |
| 3123 return dart.as(subscription, StreamSubscription$(T)); | 3123 return dart.as(subscription, StreamSubscription$(T)); |
| 3124 } | 3124 } |
| 3125 [_recordCancel](subscription) { | 3125 [_recordCancel](subscription) { |
| 3126 dart.as(subscription, StreamSubscription$(T)); | 3126 dart.as(subscription, StreamSubscription$(T)); |
| 3127 let result = null; | 3127 let result = null; |
| 3128 if (dart.notNull(this[_isAddingStream])) { | 3128 if (dart.notNull(this[_isAddingStream])) { |
| 3129 let addState = dart.as(this[_varData], _StreamControllerAddStreamState
); | 3129 let addState = dart.as(this[_varData], _StreamControllerAddStreamState
); |
| 3130 result = addState.cancel(); | 3130 result = addState.cancel(); |
| 3131 } | 3131 } |
| 3132 this[_varData] = null; | 3132 this[_varData] = null; |
| (...skipping 254 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3387 } | 3387 } |
| 3388 resume() { | 3388 resume() { |
| 3389 this.addSubscription.resume(); | 3389 this.addSubscription.resume(); |
| 3390 } | 3390 } |
| 3391 cancel() { | 3391 cancel() { |
| 3392 let cancel2 = this.addSubscription.cancel(); | 3392 let cancel2 = this.addSubscription.cancel(); |
| 3393 if (cancel2 == null) { | 3393 if (cancel2 == null) { |
| 3394 this.addStreamFuture[_asyncComplete](null); | 3394 this.addStreamFuture[_asyncComplete](null); |
| 3395 return null; | 3395 return null; |
| 3396 } | 3396 } |
| 3397 return cancel2.whenComplete(dart.fn((() => { | 3397 return cancel2.whenComplete(dart.fn(() => { |
| 3398 this.addStreamFuture[_asyncComplete](null); | 3398 this.addStreamFuture[_asyncComplete](null); |
| 3399 }).bind(this))); | 3399 })); |
| 3400 } | 3400 } |
| 3401 complete() { | 3401 complete() { |
| 3402 this.addStreamFuture[_asyncComplete](null); | 3402 this.addStreamFuture[_asyncComplete](null); |
| 3403 } | 3403 } |
| 3404 } | 3404 } |
| 3405 dart.setSignature(_AddStreamState, { | 3405 dart.setSignature(_AddStreamState, { |
| 3406 constructors: () => ({_AddStreamState: [_AddStreamState$(T), [_EventSink$(
T), Stream, core.bool]]}), | 3406 constructors: () => ({_AddStreamState: [_AddStreamState$(T), [_EventSink$(
T), Stream, core.bool]]}), |
| 3407 methods: () => ({ | 3407 methods: () => ({ |
| 3408 pause: [dart.void, []], | 3408 pause: [dart.void, []], |
| 3409 resume: [dart.void, []], | 3409 resume: [dart.void, []], |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3479 return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SC
HEDULED); | 3479 return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SC
HEDULED); |
| 3480 } | 3480 } |
| 3481 schedule(dispatch) { | 3481 schedule(dispatch) { |
| 3482 if (dart.notNull(this.isScheduled)) return; | 3482 if (dart.notNull(this.isScheduled)) return; |
| 3483 dart.assert(!dart.notNull(this.isEmpty)); | 3483 dart.assert(!dart.notNull(this.isEmpty)); |
| 3484 if (dart.notNull(this[_eventScheduled])) { | 3484 if (dart.notNull(this[_eventScheduled])) { |
| 3485 dart.assert(this[_state] == _PendingEvents._STATE_CANCELED); | 3485 dart.assert(this[_state] == _PendingEvents._STATE_CANCELED); |
| 3486 this[_state] = _PendingEvents._STATE_SCHEDULED; | 3486 this[_state] = _PendingEvents._STATE_SCHEDULED; |
| 3487 return; | 3487 return; |
| 3488 } | 3488 } |
| 3489 scheduleMicrotask(dart.fn((() => { | 3489 scheduleMicrotask(dart.fn(() => { |
| 3490 let oldState = this[_state]; | 3490 let oldState = this[_state]; |
| 3491 this[_state] = _PendingEvents._STATE_UNSCHEDULED; | 3491 this[_state] = _PendingEvents._STATE_UNSCHEDULED; |
| 3492 if (oldState == _PendingEvents._STATE_CANCELED) return; | 3492 if (oldState == _PendingEvents._STATE_CANCELED) return; |
| 3493 this.handleNext(dispatch); | 3493 this.handleNext(dispatch); |
| 3494 }).bind(this), dart.void, [])); | 3494 }, dart.void, [])); |
| 3495 this[_state] = _PendingEvents._STATE_SCHEDULED; | 3495 this[_state] = _PendingEvents._STATE_SCHEDULED; |
| 3496 } | 3496 } |
| 3497 cancelSchedule() { | 3497 cancelSchedule() { |
| 3498 if (dart.notNull(this.isScheduled)) this[_state] = _PendingEvents._STATE_C
ANCELED; | 3498 if (dart.notNull(this.isScheduled)) this[_state] = _PendingEvents._STATE_C
ANCELED; |
| 3499 } | 3499 } |
| 3500 } | 3500 } |
| 3501 dart.setSignature(_PendingEvents, { | 3501 dart.setSignature(_PendingEvents, { |
| 3502 methods: () => ({ | 3502 methods: () => ({ |
| 3503 schedule: [dart.void, [_EventDispatch]], | 3503 schedule: [dart.void, [_EventDispatch]], |
| 3504 cancelSchedule: [dart.void, []] | 3504 cancelSchedule: [dart.void, []] |
| (...skipping 1714 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5219 } catch (e) { | 5219 } catch (e) { |
| 5220 let s = dart.stackTrace(e); | 5220 let s = dart.stackTrace(e); |
| 5221 return this.handleUncaughtError(e, s); | 5221 return this.handleUncaughtError(e, s); |
| 5222 } | 5222 } |
| 5223 | 5223 |
| 5224 } | 5224 } |
| 5225 bindCallback(f, opts) { | 5225 bindCallback(f, opts) { |
| 5226 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5226 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5227 let registered = this.registerCallback(f); | 5227 let registered = this.registerCallback(f); |
| 5228 if (dart.notNull(runGuarded)) { | 5228 if (dart.notNull(runGuarded)) { |
| 5229 return dart.fn((() => this.runGuarded(registered)).bind(this)); | 5229 return dart.fn(() => this.runGuarded(registered)); |
| 5230 } else { | 5230 } else { |
| 5231 return dart.fn((() => this.run(registered)).bind(this)); | 5231 return dart.fn(() => this.run(registered)); |
| 5232 } | 5232 } |
| 5233 } | 5233 } |
| 5234 bindUnaryCallback(f, opts) { | 5234 bindUnaryCallback(f, opts) { |
| 5235 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5235 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5236 let registered = this.registerUnaryCallback(f); | 5236 let registered = this.registerUnaryCallback(f); |
| 5237 if (dart.notNull(runGuarded)) { | 5237 if (dart.notNull(runGuarded)) { |
| 5238 return dart.fn((arg => this.runUnaryGuarded(registered, arg)).bind(this)
); | 5238 return dart.fn(arg => this.runUnaryGuarded(registered, arg)); |
| 5239 } else { | 5239 } else { |
| 5240 return dart.fn((arg => this.runUnary(registered, arg)).bind(this)); | 5240 return dart.fn(arg => this.runUnary(registered, arg)); |
| 5241 } | 5241 } |
| 5242 } | 5242 } |
| 5243 bindBinaryCallback(f, opts) { | 5243 bindBinaryCallback(f, opts) { |
| 5244 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5244 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5245 let registered = this.registerBinaryCallback(f); | 5245 let registered = this.registerBinaryCallback(f); |
| 5246 if (dart.notNull(runGuarded)) { | 5246 if (dart.notNull(runGuarded)) { |
| 5247 return dart.fn(((arg1, arg2) => this.runBinaryGuarded(registered, arg1,
arg2)).bind(this)); | 5247 return dart.fn((arg1, arg2) => this.runBinaryGuarded(registered, arg1, a
rg2)); |
| 5248 } else { | 5248 } else { |
| 5249 return dart.fn(((arg1, arg2) => this.runBinary(registered, arg1, arg2)).
bind(this)); | 5249 return dart.fn((arg1, arg2) => this.runBinary(registered, arg1, arg2)); |
| 5250 } | 5250 } |
| 5251 } | 5251 } |
| 5252 get(key) { | 5252 get(key) { |
| 5253 let result = this[_map].get(key); | 5253 let result = this[_map].get(key); |
| 5254 if (result != null || dart.notNull(this[_map].containsKey(key))) return re
sult; | 5254 if (result != null || dart.notNull(this[_map].containsKey(key))) return re
sult; |
| 5255 if (this.parent != null) { | 5255 if (this.parent != null) { |
| 5256 let value = this.parent.get(key); | 5256 let value = this.parent.get(key); |
| 5257 if (value != null) { | 5257 if (value != null) { |
| 5258 this[_map].set(key, value); | 5258 this[_map].set(key, value); |
| 5259 } | 5259 } |
| (...skipping 342 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5602 return _rootRunBinary(null, null, this, f, arg1, arg2); | 5602 return _rootRunBinary(null, null, this, f, arg1, arg2); |
| 5603 } catch (e) { | 5603 } catch (e) { |
| 5604 let s = dart.stackTrace(e); | 5604 let s = dart.stackTrace(e); |
| 5605 return this.handleUncaughtError(e, s); | 5605 return this.handleUncaughtError(e, s); |
| 5606 } | 5606 } |
| 5607 | 5607 |
| 5608 } | 5608 } |
| 5609 bindCallback(f, opts) { | 5609 bindCallback(f, opts) { |
| 5610 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5610 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5611 if (dart.notNull(runGuarded)) { | 5611 if (dart.notNull(runGuarded)) { |
| 5612 return dart.fn((() => this.runGuarded(f)).bind(this)); | 5612 return dart.fn(() => this.runGuarded(f)); |
| 5613 } else { | 5613 } else { |
| 5614 return dart.fn((() => this.run(f)).bind(this)); | 5614 return dart.fn(() => this.run(f)); |
| 5615 } | 5615 } |
| 5616 } | 5616 } |
| 5617 bindUnaryCallback(f, opts) { | 5617 bindUnaryCallback(f, opts) { |
| 5618 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5618 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5619 if (dart.notNull(runGuarded)) { | 5619 if (dart.notNull(runGuarded)) { |
| 5620 return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this)); | 5620 return dart.fn(arg => this.runUnaryGuarded(f, arg)); |
| 5621 } else { | 5621 } else { |
| 5622 return dart.fn((arg => this.runUnary(f, arg)).bind(this)); | 5622 return dart.fn(arg => this.runUnary(f, arg)); |
| 5623 } | 5623 } |
| 5624 } | 5624 } |
| 5625 bindBinaryCallback(f, opts) { | 5625 bindBinaryCallback(f, opts) { |
| 5626 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5626 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5627 if (dart.notNull(runGuarded)) { | 5627 if (dart.notNull(runGuarded)) { |
| 5628 return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bi
nd(this)); | 5628 return dart.fn((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)); |
| 5629 } else { | 5629 } else { |
| 5630 return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this
)); | 5630 return dart.fn((arg1, arg2) => this.runBinary(f, arg1, arg2)); |
| 5631 } | 5631 } |
| 5632 } | 5632 } |
| 5633 get(key) { | 5633 get(key) { |
| 5634 return null; | 5634 return null; |
| 5635 } | 5635 } |
| 5636 handleUncaughtError(error, stackTrace) { | 5636 handleUncaughtError(error, stackTrace) { |
| 5637 return _rootHandleUncaughtError(null, null, this, error, stackTrace); | 5637 return _rootHandleUncaughtError(null, null, this, error, stackTrace); |
| 5638 } | 5638 } |
| 5639 fork(opts) { | 5639 fork(opts) { |
| 5640 let specification = opts && 'specification' in opts ? opts.specification :
null; | 5640 let specification = opts && 'specification' in opts ? opts.specification :
null; |
| (...skipping 169 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5810 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5810 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5811 exports.CreateTimerHandler = CreateTimerHandler; | 5811 exports.CreateTimerHandler = CreateTimerHandler; |
| 5812 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5812 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5813 exports.PrintHandler = PrintHandler; | 5813 exports.PrintHandler = PrintHandler; |
| 5814 exports.ForkHandler = ForkHandler; | 5814 exports.ForkHandler = ForkHandler; |
| 5815 exports.ZoneSpecification = ZoneSpecification; | 5815 exports.ZoneSpecification = ZoneSpecification; |
| 5816 exports.ZoneDelegate = ZoneDelegate; | 5816 exports.ZoneDelegate = ZoneDelegate; |
| 5817 exports.Zone = Zone; | 5817 exports.Zone = Zone; |
| 5818 exports.runZoned = runZoned; | 5818 exports.runZoned = runZoned; |
| 5819 }); | 5819 }); |
| OLD | NEW |