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 } |
11 } | 11 } |
12 // Function _registerErrorHandler: (Function, Zone) → Function | 12 // Function _registerErrorHandler: (Function, Zone) → Function |
13 function _registerErrorHandler(errorHandler, zone) { | 13 function _registerErrorHandler(errorHandler, zone) { |
14 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 14 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
15 return zone.registerBinaryCallback(errorHandler); | 15 return zone.registerBinaryCallback(errorHandler); |
16 } else { | 16 } else { |
17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.functionType(
dart.dynamic, [dart.dynamic]))); | 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.functionType(
dart.dynamic, [dart.dynamic]))); |
18 } | 18 } |
19 } | 19 } |
20 let _getBestStackTrace = Symbol('_getBestStackTrace'); | 20 let _getBestStackTrace = Symbol('_getBestStackTrace'); |
| 21 let error$ = Symbol('error'); |
| 22 let stackTrace$ = Symbol('stackTrace'); |
21 class AsyncError extends core.Object { | 23 class AsyncError extends core.Object { |
| 24 get error() { |
| 25 return this[error$]; |
| 26 } |
| 27 get stackTrace() { |
| 28 return this[stackTrace$]; |
| 29 } |
22 AsyncError(error, stackTrace) { | 30 AsyncError(error, stackTrace) { |
23 this.error = error; | 31 this[error$] = error; |
24 this.stackTrace = stackTrace; | 32 this[stackTrace$] = stackTrace; |
25 } | 33 } |
26 toString() { | 34 toString() { |
27 return this.error.toString(); | 35 return this.error.toString(); |
28 } | 36 } |
29 } | 37 } |
30 AsyncError[dart.implements] = () => [core.Error]; | 38 AsyncError[dart.implements] = () => [core.Error]; |
31 class _UncaughtAsyncError extends AsyncError { | 39 class _UncaughtAsyncError extends AsyncError { |
32 _UncaughtAsyncError(error, stackTrace) { | 40 _UncaughtAsyncError(error, stackTrace) { |
33 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta
ckTrace)); | 41 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta
ckTrace)); |
34 } | 42 } |
(...skipping 804 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
839 let _expectsEvent = Symbol('_expectsEvent'); | 847 let _expectsEvent = Symbol('_expectsEvent'); |
840 let _STATE_EVENT_ID = Symbol('_STATE_EVENT_ID'); | 848 let _STATE_EVENT_ID = Symbol('_STATE_EVENT_ID'); |
841 let _toggleEventId = Symbol('_toggleEventId'); | 849 let _toggleEventId = Symbol('_toggleEventId'); |
842 let _isFiring = Symbol('_isFiring'); | 850 let _isFiring = Symbol('_isFiring'); |
843 let _STATE_FIRING = Symbol('_STATE_FIRING'); | 851 let _STATE_FIRING = Symbol('_STATE_FIRING'); |
844 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); | 852 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); |
845 let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING'); | 853 let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING'); |
846 let _removeAfterFiring = Symbol('_removeAfterFiring'); | 854 let _removeAfterFiring = Symbol('_removeAfterFiring'); |
847 let _onPause = Symbol('_onPause'); | 855 let _onPause = Symbol('_onPause'); |
848 let _onResume = Symbol('_onResume'); | 856 let _onResume = Symbol('_onResume'); |
| 857 let _controller$ = Symbol('_controller'); |
849 let _onCancel = Symbol('_onCancel'); | 858 let _onCancel = Symbol('_onCancel'); |
850 let _recordCancel = Symbol('_recordCancel'); | 859 let _recordCancel = Symbol('_recordCancel'); |
851 let _recordPause = Symbol('_recordPause'); | 860 let _recordPause = Symbol('_recordPause'); |
852 let _recordResume = Symbol('_recordResume'); | 861 let _recordResume = Symbol('_recordResume'); |
| 862 let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR'); |
853 let _zone = Symbol('_zone'); | 863 let _zone = Symbol('_zone'); |
854 let _state = Symbol('_state'); | 864 let _state = Symbol('_state'); |
855 let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR'); | |
856 let _onData = Symbol('_onData'); | 865 let _onData = Symbol('_onData'); |
857 let _onError = Symbol('_onError'); | 866 let _onError = Symbol('_onError'); |
858 let _onDone = Symbol('_onDone'); | 867 let _onDone = Symbol('_onDone'); |
859 let _cancelFuture = Symbol('_cancelFuture'); | 868 let _cancelFuture = Symbol('_cancelFuture'); |
860 let _pending = Symbol('_pending'); | 869 let _pending = Symbol('_pending'); |
861 let _setPendingEvents = Symbol('_setPendingEvents'); | 870 let _setPendingEvents = Symbol('_setPendingEvents'); |
862 let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING'); | 871 let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING'); |
863 let _extractPending = Symbol('_extractPending'); | 872 let _extractPending = Symbol('_extractPending'); |
864 let _isCanceled = Symbol('_isCanceled'); | 873 let _isCanceled = Symbol('_isCanceled'); |
865 let _isPaused = Symbol('_isPaused'); | 874 let _isPaused = Symbol('_isPaused'); |
(...skipping 325 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1191 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; | 1200 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; |
1192 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; | 1201 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; |
1193 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; | 1202 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; |
1194 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; | 1203 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; |
1195 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; | 1204 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; |
1196 return _BufferingStreamSubscription; | 1205 return _BufferingStreamSubscription; |
1197 }); | 1206 }); |
1198 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); | 1207 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); |
1199 let _ControllerSubscription$ = dart.generic(function(T) { | 1208 let _ControllerSubscription$ = dart.generic(function(T) { |
1200 class _ControllerSubscription extends _BufferingStreamSubscription$(T) { | 1209 class _ControllerSubscription extends _BufferingStreamSubscription$(T) { |
| 1210 get [_controller]() { |
| 1211 return this[_controller$]; |
| 1212 } |
1201 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError
) { | 1213 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError
) { |
1202 this[_controller] = controller; | 1214 this[_controller$] = controller; |
1203 super._BufferingStreamSubscription(onData, onError, onDone, cancelOnErro
r); | 1215 super._BufferingStreamSubscription(onData, onError, onDone, cancelOnErro
r); |
1204 } | 1216 } |
1205 [_onCancel]() { | 1217 [_onCancel]() { |
1206 return this[_controller][_recordCancel](this); | 1218 return this[_controller][_recordCancel](this); |
1207 } | 1219 } |
1208 [_onPause]() { | 1220 [_onPause]() { |
1209 this[_controller][_recordPause](this); | 1221 this[_controller][_recordPause](this); |
1210 } | 1222 } |
1211 [_onResume]() { | 1223 [_onResume]() { |
1212 this[_controller][_recordResume](this); | 1224 this[_controller][_recordResume](this); |
(...skipping 431 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1644 asFuture(value) { | 1656 asFuture(value) { |
1645 if (value === void 0) | 1657 if (value === void 0) |
1646 value = null; | 1658 value = null; |
1647 return new _Future(); | 1659 return new _Future(); |
1648 } | 1660 } |
1649 } | 1661 } |
1650 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; | 1662 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
1651 return _DoneSubscription; | 1663 return _DoneSubscription; |
1652 }); | 1664 }); |
1653 let _DoneSubscription = _DoneSubscription$(); | 1665 let _DoneSubscription = _DoneSubscription$(); |
| 1666 let libraryName$ = Symbol('libraryName'); |
| 1667 let uri$ = Symbol('uri'); |
1654 class DeferredLibrary extends core.Object { | 1668 class DeferredLibrary extends core.Object { |
| 1669 get libraryName() { |
| 1670 return this[libraryName$]; |
| 1671 } |
| 1672 get uri() { |
| 1673 return this[uri$]; |
| 1674 } |
1655 DeferredLibrary(libraryName, opts) { | 1675 DeferredLibrary(libraryName, opts) { |
1656 let uri = opts && 'uri' in opts ? opts.uri : null; | 1676 let uri = opts && 'uri' in opts ? opts.uri : null; |
1657 this.libraryName = libraryName; | 1677 this[libraryName$] = libraryName; |
1658 this.uri = uri; | 1678 this[uri$] = uri; |
1659 } | 1679 } |
1660 load() { | 1680 load() { |
1661 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; | 1681 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; |
1662 } | 1682 } |
1663 } | 1683 } |
1664 let _s = Symbol('_s'); | 1684 let _s = Symbol('_s'); |
1665 class DeferredLoadException extends core.Object { | 1685 class DeferredLoadException extends core.Object { |
1666 DeferredLoadException(s) { | 1686 DeferredLoadException(s) { |
1667 this[_s] = s; | 1687 this[_s] = s; |
1668 } | 1688 } |
(...skipping 162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1831 dart.defineNamedConstructor(Future, 'error'); | 1851 dart.defineNamedConstructor(Future, 'error'); |
1832 dart.defineNamedConstructor(Future, 'delayed'); | 1852 dart.defineNamedConstructor(Future, 'delayed'); |
1833 dart.defineLazyProperties(Future, { | 1853 dart.defineLazyProperties(Future, { |
1834 get _nullFuture() { | 1854 get _nullFuture() { |
1835 return new Future.value(null); | 1855 return new Future.value(null); |
1836 } | 1856 } |
1837 }); | 1857 }); |
1838 return Future; | 1858 return Future; |
1839 }); | 1859 }); |
1840 let Future = Future$(); | 1860 let Future = Future$(); |
| 1861 let message$ = Symbol('message'); |
| 1862 let duration$ = Symbol('duration'); |
1841 class TimeoutException extends core.Object { | 1863 class TimeoutException extends core.Object { |
| 1864 get message() { |
| 1865 return this[message$]; |
| 1866 } |
| 1867 get duration() { |
| 1868 return this[duration$]; |
| 1869 } |
1842 TimeoutException(message, duration) { | 1870 TimeoutException(message, duration) { |
1843 if (duration === void 0) | 1871 if (duration === void 0) |
1844 duration = null; | 1872 duration = null; |
1845 this.message = message; | 1873 this[message$] = message; |
1846 this.duration = duration; | 1874 this[duration$] = duration; |
1847 } | 1875 } |
1848 toString() { | 1876 toString() { |
1849 let result = "TimeoutException"; | 1877 let result = "TimeoutException"; |
1850 if (this.duration != null) | 1878 if (this.duration != null) |
1851 result = `TimeoutException after ${this.duration}`; | 1879 result = `TimeoutException after ${this.duration}`; |
1852 if (this.message != null) | 1880 if (this.message != null) |
1853 result = `${result}: ${this.message}`; | 1881 result = `${result}: ${this.message}`; |
1854 return result; | 1882 return result; |
1855 } | 1883 } |
1856 } | 1884 } |
(...skipping 1146 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3003 this[_subscription][_addPending](new _DelayedError(error, stackTrace)); | 3031 this[_subscription][_addPending](new _DelayedError(error, stackTrace)); |
3004 } | 3032 } |
3005 [_sendDone]() { | 3033 [_sendDone]() { |
3006 this[_subscription][_addPending](new _DelayedDone()); | 3034 this[_subscription][_addPending](new _DelayedDone()); |
3007 } | 3035 } |
3008 } | 3036 } |
3009 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(
T)]; | 3037 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(
T)]; |
3010 return _AsyncStreamControllerDispatch; | 3038 return _AsyncStreamControllerDispatch; |
3011 }); | 3039 }); |
3012 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(); | 3040 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(); |
| 3041 let _onListen$ = Symbol('_onListen'); |
| 3042 let _onPause$ = Symbol('_onPause'); |
| 3043 let _onResume$ = Symbol('_onResume'); |
| 3044 let _onCancel$ = Symbol('_onCancel'); |
3013 let _AsyncStreamController$ = dart.generic(function(T) { | 3045 let _AsyncStreamController$ = dart.generic(function(T) { |
3014 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { | 3046 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { |
| 3047 get [_onListen]() { |
| 3048 return this[_onListen$]; |
| 3049 } |
| 3050 get [_onPause]() { |
| 3051 return this[_onPause$]; |
| 3052 } |
| 3053 get [_onResume]() { |
| 3054 return this[_onResume$]; |
| 3055 } |
| 3056 get [_onCancel]() { |
| 3057 return this[_onCancel$]; |
| 3058 } |
3015 _AsyncStreamController(onListen, onPause, onResume, onCancel) { | 3059 _AsyncStreamController(onListen, onPause, onResume, onCancel) { |
3016 this[_onListen] = onListen; | 3060 this[_onListen$] = onListen; |
3017 this[_onPause] = onPause; | 3061 this[_onPause$] = onPause; |
3018 this[_onResume] = onResume; | 3062 this[_onResume$] = onResume; |
3019 this[_onCancel] = onCancel; | 3063 this[_onCancel$] = onCancel; |
3020 super._StreamController(); | 3064 super._StreamController(); |
3021 } | 3065 } |
3022 } | 3066 } |
3023 return _AsyncStreamController; | 3067 return _AsyncStreamController; |
3024 }); | 3068 }); |
3025 let _AsyncStreamController = _AsyncStreamController$(); | 3069 let _AsyncStreamController = _AsyncStreamController$(); |
| 3070 let _onListen$0 = Symbol('_onListen'); |
| 3071 let _onPause$0 = Symbol('_onPause'); |
| 3072 let _onResume$0 = Symbol('_onResume'); |
| 3073 let _onCancel$0 = Symbol('_onCancel'); |
3026 let _SyncStreamController$ = dart.generic(function(T) { | 3074 let _SyncStreamController$ = dart.generic(function(T) { |
3027 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS
treamControllerDispatch$(T)) { | 3075 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS
treamControllerDispatch$(T)) { |
| 3076 get [_onListen]() { |
| 3077 return this[_onListen$0]; |
| 3078 } |
| 3079 get [_onPause]() { |
| 3080 return this[_onPause$0]; |
| 3081 } |
| 3082 get [_onResume]() { |
| 3083 return this[_onResume$0]; |
| 3084 } |
| 3085 get [_onCancel]() { |
| 3086 return this[_onCancel$0]; |
| 3087 } |
3028 _SyncStreamController(onListen, onPause, onResume, onCancel) { | 3088 _SyncStreamController(onListen, onPause, onResume, onCancel) { |
3029 this[_onListen] = onListen; | 3089 this[_onListen$0] = onListen; |
3030 this[_onPause] = onPause; | 3090 this[_onPause$0] = onPause; |
3031 this[_onResume] = onResume; | 3091 this[_onResume$0] = onResume; |
3032 this[_onCancel] = onCancel; | 3092 this[_onCancel$0] = onCancel; |
3033 super._StreamController(); | 3093 super._StreamController(); |
3034 } | 3094 } |
3035 } | 3095 } |
3036 return _SyncStreamController; | 3096 return _SyncStreamController; |
3037 }); | 3097 }); |
3038 let _SyncStreamController = _SyncStreamController$(); | 3098 let _SyncStreamController = _SyncStreamController$(); |
3039 class _NoCallbacks extends core.Object { | 3099 class _NoCallbacks extends core.Object { |
3040 get [_onListen]() { | 3100 get [_onListen]() { |
3041 return null; | 3101 return null; |
3042 } | 3102 } |
(...skipping 512 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3555 asFuture(futureValue) { | 3615 asFuture(futureValue) { |
3556 if (futureValue === void 0) | 3616 if (futureValue === void 0) |
3557 futureValue = null; | 3617 futureValue = null; |
3558 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); | 3618 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); |
3559 } | 3619 } |
3560 } | 3620 } |
3561 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; | 3621 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; |
3562 return _BroadcastSubscriptionWrapper; | 3622 return _BroadcastSubscriptionWrapper; |
3563 }); | 3623 }); |
3564 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); | 3624 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); |
| 3625 let _STATE_FOUND = Symbol('_STATE_FOUND'); |
3565 let _current = Symbol('_current'); | 3626 let _current = Symbol('_current'); |
3566 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); | 3627 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); |
3567 let _STATE_FOUND = Symbol('_STATE_FOUND'); | |
3568 let _STATE_DONE = Symbol('_STATE_DONE'); | 3628 let _STATE_DONE = Symbol('_STATE_DONE'); |
3569 let _STATE_MOVING = Symbol('_STATE_MOVING'); | 3629 let _STATE_MOVING = Symbol('_STATE_MOVING'); |
3570 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); | 3630 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); |
3571 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); | 3631 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); |
3572 let _clear = Symbol('_clear'); | 3632 let _clear = Symbol('_clear'); |
3573 let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE'); | 3633 let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE'); |
3574 let _StreamIteratorImpl$ = dart.generic(function(T) { | 3634 let _StreamIteratorImpl$ = dart.generic(function(T) { |
3575 class _StreamIteratorImpl extends core.Object { | 3635 class _StreamIteratorImpl extends core.Object { |
3576 _StreamIteratorImpl(stream) { | 3636 _StreamIteratorImpl(stream) { |
3577 this[_subscription] = null; | 3637 this[_subscription] = null; |
(...skipping 1006 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4584 } | 4644 } |
4585 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; | 4645 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; |
4586 class _Zone extends core.Object { | 4646 class _Zone extends core.Object { |
4587 _Zone() { | 4647 _Zone() { |
4588 } | 4648 } |
4589 inSameErrorZone(otherZone) { | 4649 inSameErrorZone(otherZone) { |
4590 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); | 4650 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); |
4591 } | 4651 } |
4592 } | 4652 } |
4593 _Zone[dart.implements] = () => [Zone]; | 4653 _Zone[dart.implements] = () => [Zone]; |
| 4654 let _runUnary$ = Symbol('_runUnary'); |
| 4655 let _run$ = Symbol('_run'); |
| 4656 let _runBinary$ = Symbol('_runBinary'); |
| 4657 let _registerCallback$ = Symbol('_registerCallback'); |
| 4658 let _registerUnaryCallback$ = Symbol('_registerUnaryCallback'); |
| 4659 let _registerBinaryCallback$ = Symbol('_registerBinaryCallback'); |
| 4660 let _errorCallback$ = Symbol('_errorCallback'); |
| 4661 let _scheduleMicrotask$ = Symbol('_scheduleMicrotask'); |
| 4662 let _createTimer$ = Symbol('_createTimer'); |
| 4663 let _createPeriodicTimer$ = Symbol('_createPeriodicTimer'); |
| 4664 let _print$ = Symbol('_print'); |
| 4665 let _fork$ = Symbol('_fork'); |
| 4666 let _handleUncaughtError$ = Symbol('_handleUncaughtError'); |
| 4667 let parent$ = Symbol('parent'); |
| 4668 let _map = Symbol('_map'); |
| 4669 let _map$ = Symbol('_map'); |
4594 let _delegateCache = Symbol('_delegateCache'); | 4670 let _delegateCache = Symbol('_delegateCache'); |
4595 let _map = Symbol('_map'); | |
4596 class _CustomZone extends _Zone { | 4671 class _CustomZone extends _Zone { |
| 4672 get [_runUnary]() { |
| 4673 return this[_runUnary$]; |
| 4674 } |
| 4675 set [_runUnary](value) { |
| 4676 this[_runUnary$] = value; |
| 4677 } |
| 4678 get [_run]() { |
| 4679 return this[_run$]; |
| 4680 } |
| 4681 set [_run](value) { |
| 4682 this[_run$] = value; |
| 4683 } |
| 4684 get [_runBinary]() { |
| 4685 return this[_runBinary$]; |
| 4686 } |
| 4687 set [_runBinary](value) { |
| 4688 this[_runBinary$] = value; |
| 4689 } |
| 4690 get [_registerCallback]() { |
| 4691 return this[_registerCallback$]; |
| 4692 } |
| 4693 set [_registerCallback](value) { |
| 4694 this[_registerCallback$] = value; |
| 4695 } |
| 4696 get [_registerUnaryCallback]() { |
| 4697 return this[_registerUnaryCallback$]; |
| 4698 } |
| 4699 set [_registerUnaryCallback](value) { |
| 4700 this[_registerUnaryCallback$] = value; |
| 4701 } |
| 4702 get [_registerBinaryCallback]() { |
| 4703 return this[_registerBinaryCallback$]; |
| 4704 } |
| 4705 set [_registerBinaryCallback](value) { |
| 4706 this[_registerBinaryCallback$] = value; |
| 4707 } |
| 4708 get [_errorCallback]() { |
| 4709 return this[_errorCallback$]; |
| 4710 } |
| 4711 set [_errorCallback](value) { |
| 4712 this[_errorCallback$] = value; |
| 4713 } |
| 4714 get [_scheduleMicrotask]() { |
| 4715 return this[_scheduleMicrotask$]; |
| 4716 } |
| 4717 set [_scheduleMicrotask](value) { |
| 4718 this[_scheduleMicrotask$] = value; |
| 4719 } |
| 4720 get [_createTimer]() { |
| 4721 return this[_createTimer$]; |
| 4722 } |
| 4723 set [_createTimer](value) { |
| 4724 this[_createTimer$] = value; |
| 4725 } |
| 4726 get [_createPeriodicTimer]() { |
| 4727 return this[_createPeriodicTimer$]; |
| 4728 } |
| 4729 set [_createPeriodicTimer](value) { |
| 4730 this[_createPeriodicTimer$] = value; |
| 4731 } |
| 4732 get [_print]() { |
| 4733 return this[_print$]; |
| 4734 } |
| 4735 set [_print](value) { |
| 4736 this[_print$] = value; |
| 4737 } |
| 4738 get [_fork]() { |
| 4739 return this[_fork$]; |
| 4740 } |
| 4741 set [_fork](value) { |
| 4742 this[_fork$] = value; |
| 4743 } |
| 4744 get [_handleUncaughtError]() { |
| 4745 return this[_handleUncaughtError$]; |
| 4746 } |
| 4747 set [_handleUncaughtError](value) { |
| 4748 this[_handleUncaughtError$] = value; |
| 4749 } |
| 4750 get parent() { |
| 4751 return this[parent$]; |
| 4752 } |
| 4753 get [_map$]() { |
| 4754 return this[_map]; |
| 4755 } |
4597 get [_delegate]() { | 4756 get [_delegate]() { |
4598 if (this[_delegateCache] != null) | 4757 if (this[_delegateCache] != null) |
4599 return this[_delegateCache]; | 4758 return this[_delegateCache]; |
4600 this[_delegateCache] = new _ZoneDelegate(this); | 4759 this[_delegateCache] = new _ZoneDelegate(this); |
4601 return this[_delegateCache]; | 4760 return this[_delegateCache]; |
4602 } | 4761 } |
4603 _CustomZone(parent, specification, map) { | 4762 _CustomZone(parent, specification, map) { |
4604 this.parent = parent; | 4763 this[parent$] = parent; |
4605 this[_map] = map; | 4764 this[_map] = map; |
4606 this[_runUnary] = null; | 4765 this[_runUnary$] = null; |
4607 this[_run] = null; | 4766 this[_run$] = null; |
4608 this[_runBinary] = null; | 4767 this[_runBinary$] = null; |
4609 this[_registerCallback] = null; | 4768 this[_registerCallback$] = null; |
4610 this[_registerUnaryCallback] = null; | 4769 this[_registerUnaryCallback$] = null; |
4611 this[_registerBinaryCallback] = null; | 4770 this[_registerBinaryCallback$] = null; |
4612 this[_errorCallback] = null; | 4771 this[_errorCallback$] = null; |
4613 this[_scheduleMicrotask] = null; | 4772 this[_scheduleMicrotask$] = null; |
4614 this[_createTimer] = null; | 4773 this[_createTimer$] = null; |
4615 this[_createPeriodicTimer] = null; | 4774 this[_createPeriodicTimer$] = null; |
4616 this[_print] = null; | 4775 this[_print$] = null; |
4617 this[_fork] = null; | 4776 this[_fork$] = null; |
4618 this[_handleUncaughtError] = null; | 4777 this[_handleUncaughtError$] = null; |
4619 this[_delegateCache] = null; | 4778 this[_delegateCache] = null; |
4620 super._Zone(); | 4779 super._Zone(); |
4621 this[_run] = specification.run != null ? new _ZoneFunction(this, specifica
tion.run) : this.parent[_run]; | 4780 this[_run] = specification.run != null ? new _ZoneFunction(this, specifica
tion.run) : this.parent[_run]; |
4622 this[_runUnary] = specification.runUnary != null ? new _ZoneFunction(this,
specification.runUnary) : this.parent[_runUnary]; | 4781 this[_runUnary] = specification.runUnary != null ? new _ZoneFunction(this,
specification.runUnary) : this.parent[_runUnary]; |
4623 this[_runBinary] = specification.runBinary != null ? new _ZoneFunction(thi
s, specification.runBinary) : this.parent[_runBinary]; | 4782 this[_runBinary] = specification.runBinary != null ? new _ZoneFunction(thi
s, specification.runBinary) : this.parent[_runBinary]; |
4624 this[_registerCallback] = specification.registerCallback != null ? new _Zo
neFunction(this, specification.registerCallback) : this.parent[_registerCallback
]; | 4783 this[_registerCallback] = specification.registerCallback != null ? new _Zo
neFunction(this, specification.registerCallback) : this.parent[_registerCallback
]; |
4625 this[_registerUnaryCallback] = specification.registerUnaryCallback != null
? new _ZoneFunction(this, specification.registerUnaryCallback) : this.parent[_r
egisterUnaryCallback]; | 4784 this[_registerUnaryCallback] = specification.registerUnaryCallback != null
? new _ZoneFunction(this, specification.registerUnaryCallback) : this.parent[_r
egisterUnaryCallback]; |
4626 this[_registerBinaryCallback] = specification.registerBinaryCallback != nu
ll ? new _ZoneFunction(this, specification.registerBinaryCallback) : this.parent
[_registerBinaryCallback]; | 4785 this[_registerBinaryCallback] = specification.registerBinaryCallback != nu
ll ? new _ZoneFunction(this, specification.registerBinaryCallback) : this.parent
[_registerBinaryCallback]; |
4627 this[_errorCallback] = specification.errorCallback != null ? new _ZoneFunc
tion(this, specification.errorCallback) : this.parent[_errorCallback]; | 4786 this[_errorCallback] = specification.errorCallback != null ? new _ZoneFunc
tion(this, specification.errorCallback) : this.parent[_errorCallback]; |
4628 this[_scheduleMicrotask] = specification.scheduleMicrotask != null ? new _
ZoneFunction(this, specification.scheduleMicrotask) : this.parent[_scheduleMicro
task]; | 4787 this[_scheduleMicrotask] = specification.scheduleMicrotask != null ? new _
ZoneFunction(this, specification.scheduleMicrotask) : this.parent[_scheduleMicro
task]; |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4683 bindBinaryCallback(f, opts) { | 4842 bindBinaryCallback(f, opts) { |
4684 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 4843 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
4685 let registered = this.registerBinaryCallback(f); | 4844 let registered = this.registerBinaryCallback(f); |
4686 if (runGuarded) { | 4845 if (runGuarded) { |
4687 return ((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2)).b
ind(this); | 4846 return ((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2)).b
ind(this); |
4688 } else { | 4847 } else { |
4689 return ((arg1, arg2) => this.runBinary(registered, arg1, arg2)).bind(thi
s); | 4848 return ((arg1, arg2) => this.runBinary(registered, arg1, arg2)).bind(thi
s); |
4690 } | 4849 } |
4691 } | 4850 } |
4692 get(key) { | 4851 get(key) { |
4693 let result = this[_map].get(key); | 4852 let result = this[_map$].get(key); |
4694 if (dart.notNull(result != null) || dart.notNull(this[_map].containsKey(ke
y))) | 4853 if (dart.notNull(result != null) || dart.notNull(this[_map$].containsKey(k
ey))) |
4695 return result; | 4854 return result; |
4696 if (this.parent != null) { | 4855 if (this.parent != null) { |
4697 let value = this.parent.get(key); | 4856 let value = this.parent.get(key); |
4698 if (value != null) { | 4857 if (value != null) { |
4699 this[_map].set(key, value); | 4858 this[_map$].set(key, value); |
4700 } | 4859 } |
4701 return value; | 4860 return value; |
4702 } | 4861 } |
4703 dart.assert(dart.equals(this, _ROOT_ZONE)); | 4862 dart.assert(dart.equals(this, _ROOT_ZONE)); |
4704 return null; | 4863 return null; |
4705 } | 4864 } |
4706 handleUncaughtError(error, stackTrace) { | 4865 handleUncaughtError(error, stackTrace) { |
4707 let implementation = this[_handleUncaughtError]; | 4866 let implementation = this[_handleUncaughtError]; |
4708 dart.assert(implementation != null); | 4867 dart.assert(implementation != null); |
4709 let parentDelegate = _parentDelegate(implementation.zone); | 4868 let parentDelegate = _parentDelegate(implementation.zone); |
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4876 function _rootFork(self, parent, zone, specification, zoneValues) { | 5035 function _rootFork(self, parent, zone, specification, zoneValues) { |
4877 _internal.printToZone = _printToZone; | 5036 _internal.printToZone = _printToZone; |
4878 if (specification == null) { | 5037 if (specification == null) { |
4879 specification = new ZoneSpecification(); | 5038 specification = new ZoneSpecification(); |
4880 } else if (!dart.is(specification, _ZoneSpecification)) { | 5039 } else if (!dart.is(specification, _ZoneSpecification)) { |
4881 throw new core.ArgumentError("ZoneSpecifications must be instantiated" + "
with the provided constructor."); | 5040 throw new core.ArgumentError("ZoneSpecifications must be instantiated" + "
with the provided constructor."); |
4882 } | 5041 } |
4883 let valueMap = null; | 5042 let valueMap = null; |
4884 if (zoneValues == null) { | 5043 if (zoneValues == null) { |
4885 if (dart.is(zone, _Zone)) { | 5044 if (dart.is(zone, _Zone)) { |
4886 valueMap = zone[_map]; | 5045 valueMap = zone[_map$]; |
4887 } else { | 5046 } else { |
4888 valueMap = new collection.HashMap(); | 5047 valueMap = new collection.HashMap(); |
4889 } | 5048 } |
4890 } else { | 5049 } else { |
4891 valueMap = new collection.HashMap.from(zoneValues); | 5050 valueMap = new collection.HashMap.from(zoneValues); |
4892 } | 5051 } |
4893 return new _CustomZone(dart.as(zone, _Zone), specification, valueMap); | 5052 return new _CustomZone(dart.as(zone, _Zone), specification, valueMap); |
4894 } | 5053 } |
4895 class _RootZoneSpecification extends core.Object { | 5054 class _RootZoneSpecification extends core.Object { |
4896 get handleUncaughtError() { | 5055 get handleUncaughtError() { |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4975 } | 5134 } |
4976 get [_fork]() { | 5135 get [_fork]() { |
4977 return new _ZoneFunction(_ROOT_ZONE, _rootFork); | 5136 return new _ZoneFunction(_ROOT_ZONE, _rootFork); |
4978 } | 5137 } |
4979 get [_handleUncaughtError]() { | 5138 get [_handleUncaughtError]() { |
4980 return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError); | 5139 return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError); |
4981 } | 5140 } |
4982 get parent() { | 5141 get parent() { |
4983 return null; | 5142 return null; |
4984 } | 5143 } |
4985 get [_map]() { | 5144 get [_map$]() { |
4986 return _RootZone[_rootMap]; | 5145 return _RootZone[_rootMap]; |
4987 } | 5146 } |
4988 get [_delegate]() { | 5147 get [_delegate]() { |
4989 if (_RootZone[_rootDelegate] != null) | 5148 if (_RootZone[_rootDelegate] != null) |
4990 return _RootZone[_rootDelegate]; | 5149 return _RootZone[_rootDelegate]; |
4991 return _RootZone[_rootDelegate] = new _ZoneDelegate(this); | 5150 return _RootZone[_rootDelegate] = new _ZoneDelegate(this); |
4992 } | 5151 } |
4993 get errorZone() { | 5152 get errorZone() { |
4994 return this; | 5153 return this; |
4995 } | 5154 } |
(...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5196 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5355 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5197 exports.CreateTimerHandler = CreateTimerHandler; | 5356 exports.CreateTimerHandler = CreateTimerHandler; |
5198 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5357 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5199 exports.PrintHandler = PrintHandler; | 5358 exports.PrintHandler = PrintHandler; |
5200 exports.ForkHandler = ForkHandler; | 5359 exports.ForkHandler = ForkHandler; |
5201 exports.ZoneSpecification = ZoneSpecification; | 5360 exports.ZoneSpecification = ZoneSpecification; |
5202 exports.ZoneDelegate = ZoneDelegate; | 5361 exports.ZoneDelegate = ZoneDelegate; |
5203 exports.Zone = Zone; | 5362 exports.Zone = Zone; |
5204 exports.runZoned = runZoned; | 5363 exports.runZoned = runZoned; |
5205 })(async || (async = {})); | 5364 })(async || (async = {})); |
OLD | NEW |