OLD | NEW |
1 var async; | 1 var async; |
2 (function(exports) { | 2 (function(exports) { |
3 'use strict'; | 3 'use strict'; |
4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic | 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic |
5 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
6 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
7 return dart.dcall(errorHandler, error, stackTrace); | 7 return dart.dcall(errorHandler, error, stackTrace); |
8 } else { | 8 } else { |
9 return dart.dcall(errorHandler, error); | 9 return dart.dcall(errorHandler, error); |
10 } | 10 } |
(...skipping 833 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
844 let _STATE_FIRING = Symbol('_STATE_FIRING'); | 844 let _STATE_FIRING = Symbol('_STATE_FIRING'); |
845 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); | 845 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); |
846 let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING'); | 846 let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING'); |
847 let _removeAfterFiring = Symbol('_removeAfterFiring'); | 847 let _removeAfterFiring = Symbol('_removeAfterFiring'); |
848 let _onPause = Symbol('_onPause'); | 848 let _onPause = Symbol('_onPause'); |
849 let _onResume = Symbol('_onResume'); | 849 let _onResume = Symbol('_onResume'); |
850 let _onCancel = Symbol('_onCancel'); | 850 let _onCancel = Symbol('_onCancel'); |
851 let _recordCancel = Symbol('_recordCancel'); | 851 let _recordCancel = Symbol('_recordCancel'); |
852 let _recordPause = Symbol('_recordPause'); | 852 let _recordPause = Symbol('_recordPause'); |
853 let _recordResume = Symbol('_recordResume'); | 853 let _recordResume = Symbol('_recordResume'); |
| 854 let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR'); |
854 let _zone = Symbol('_zone'); | 855 let _zone = Symbol('_zone'); |
855 let _state = Symbol('_state'); | 856 let _state = Symbol('_state'); |
856 let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR'); | |
857 let _onData = Symbol('_onData'); | 857 let _onData = Symbol('_onData'); |
858 let _onError = Symbol('_onError'); | 858 let _onError = Symbol('_onError'); |
859 let _onDone = Symbol('_onDone'); | 859 let _onDone = Symbol('_onDone'); |
860 let _cancelFuture = Symbol('_cancelFuture'); | 860 let _cancelFuture = Symbol('_cancelFuture'); |
861 let _pending = Symbol('_pending'); | 861 let _pending = Symbol('_pending'); |
862 let _setPendingEvents = Symbol('_setPendingEvents'); | 862 let _setPendingEvents = Symbol('_setPendingEvents'); |
863 let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING'); | 863 let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING'); |
864 let _extractPending = Symbol('_extractPending'); | 864 let _extractPending = Symbol('_extractPending'); |
865 let _isCanceled = Symbol('_isCanceled'); | 865 let _isCanceled = Symbol('_isCanceled'); |
866 let _isPaused = Symbol('_isPaused'); | 866 let _isPaused = Symbol('_isPaused'); |
(...skipping 2711 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3578 asFuture(futureValue) { | 3578 asFuture(futureValue) { |
3579 if (futureValue === void 0) | 3579 if (futureValue === void 0) |
3580 futureValue = null; | 3580 futureValue = null; |
3581 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); | 3581 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); |
3582 } | 3582 } |
3583 } | 3583 } |
3584 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; | 3584 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; |
3585 return _BroadcastSubscriptionWrapper; | 3585 return _BroadcastSubscriptionWrapper; |
3586 }); | 3586 }); |
3587 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); | 3587 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); |
| 3588 let _STATE_FOUND = Symbol('_STATE_FOUND'); |
3588 let _current = Symbol('_current'); | 3589 let _current = Symbol('_current'); |
3589 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); | 3590 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); |
3590 let _STATE_FOUND = Symbol('_STATE_FOUND'); | |
3591 let _STATE_DONE = Symbol('_STATE_DONE'); | 3591 let _STATE_DONE = Symbol('_STATE_DONE'); |
3592 let _STATE_MOVING = Symbol('_STATE_MOVING'); | 3592 let _STATE_MOVING = Symbol('_STATE_MOVING'); |
3593 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); | 3593 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); |
3594 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); | 3594 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); |
3595 let _clear = Symbol('_clear'); | 3595 let _clear = Symbol('_clear'); |
3596 let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE'); | 3596 let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE'); |
3597 let _StreamIteratorImpl$ = dart.generic(function(T) { | 3597 let _StreamIteratorImpl$ = dart.generic(function(T) { |
3598 class _StreamIteratorImpl extends core.Object { | 3598 class _StreamIteratorImpl extends core.Object { |
3599 _StreamIteratorImpl(stream) { | 3599 _StreamIteratorImpl(stream) { |
3600 this[_subscription] = null; | 3600 this[_subscription] = null; |
(...skipping 1651 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5252 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5252 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5253 exports.CreateTimerHandler = CreateTimerHandler; | 5253 exports.CreateTimerHandler = CreateTimerHandler; |
5254 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5254 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5255 exports.PrintHandler = PrintHandler; | 5255 exports.PrintHandler = PrintHandler; |
5256 exports.ForkHandler = ForkHandler; | 5256 exports.ForkHandler = ForkHandler; |
5257 exports.ZoneSpecification = ZoneSpecification; | 5257 exports.ZoneSpecification = ZoneSpecification; |
5258 exports.ZoneDelegate = ZoneDelegate; | 5258 exports.ZoneDelegate = ZoneDelegate; |
5259 exports.Zone = Zone; | 5259 exports.Zone = Zone; |
5260 exports.runZoned = runZoned; | 5260 exports.runZoned = runZoned; |
5261 })(async || (async = {})); | 5261 })(async || (async = {})); |
OLD | NEW |