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 |