| 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 1171 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1182 [_onResume]: [dart.void, []], | 1182 [_onResume]: [dart.void, []], |
| 1183 [_onCancel]: [Future, []], | 1183 [_onCancel]: [Future, []], |
| 1184 [_addPending]: [dart.void, [_DelayedEvent]], | 1184 [_addPending]: [dart.void, [_DelayedEvent]], |
| 1185 [_sendData]: [dart.void, [T]], | 1185 [_sendData]: [dart.void, [T]], |
| 1186 [_sendError]: [dart.void, [core.Object, core.StackTrace]], | 1186 [_sendError]: [dart.void, [core.Object, core.StackTrace]], |
| 1187 [_sendDone]: [dart.void, []], | 1187 [_sendDone]: [dart.void, []], |
| 1188 [_guardCallback]: [dart.void, [dart.dynamic]], | 1188 [_guardCallback]: [dart.void, [dart.dynamic]], |
| 1189 [_checkState]: [dart.void, [core.bool]] | 1189 [_checkState]: [dart.void, [core.bool]] |
| 1190 }) | 1190 }) |
| 1191 }); | 1191 }); |
| 1192 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; |
| 1193 _BufferingStreamSubscription._STATE_CLOSED = 2; |
| 1194 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; |
| 1195 _BufferingStreamSubscription._STATE_CANCELED = 8; |
| 1196 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; |
| 1197 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; |
| 1198 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; |
| 1199 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; |
| 1200 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; |
| 1192 return _BufferingStreamSubscription; | 1201 return _BufferingStreamSubscription; |
| 1193 }); | 1202 }); |
| 1194 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); | 1203 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); |
| 1195 const _recordCancel = Symbol('_recordCancel'); | 1204 const _recordCancel = Symbol('_recordCancel'); |
| 1196 const _recordPause = Symbol('_recordPause'); | 1205 const _recordPause = Symbol('_recordPause'); |
| 1197 const _recordResume = Symbol('_recordResume'); | 1206 const _recordResume = Symbol('_recordResume'); |
| 1198 const _ControllerSubscription$ = dart.generic(function(T) { | 1207 const _ControllerSubscription$ = dart.generic(function(T) { |
| 1199 class _ControllerSubscription extends _BufferingStreamSubscription$(T) { | 1208 class _ControllerSubscription extends _BufferingStreamSubscription$(T) { |
| 1200 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError
) { | 1209 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError
) { |
| 1201 this[_controller] = controller; | 1210 this[_controller] = controller; |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1253 } | 1262 } |
| 1254 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink]
; | 1263 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink]
; |
| 1255 dart.setSignature(_BroadcastSubscription, { | 1264 dart.setSignature(_BroadcastSubscription, { |
| 1256 constructors: () => ({_BroadcastSubscription: [_BroadcastSubscription$(T),
[_StreamControllerLifecycle, dart.functionType(dart.void, [T]), core.Function,
dart.functionType(dart.void, []), core.bool]]}), | 1265 constructors: () => ({_BroadcastSubscription: [_BroadcastSubscription$(T),
[_StreamControllerLifecycle, dart.functionType(dart.void, [T]), core.Function,
dart.functionType(dart.void, []), core.bool]]}), |
| 1257 methods: () => ({ | 1266 methods: () => ({ |
| 1258 [_expectsEvent]: [core.bool, [core.int]], | 1267 [_expectsEvent]: [core.bool, [core.int]], |
| 1259 [_toggleEventId]: [dart.void, []], | 1268 [_toggleEventId]: [dart.void, []], |
| 1260 [_setRemoveAfterFiring]: [dart.void, []] | 1269 [_setRemoveAfterFiring]: [dart.void, []] |
| 1261 }) | 1270 }) |
| 1262 }); | 1271 }); |
| 1272 _BroadcastSubscription._STATE_EVENT_ID = 1; |
| 1273 _BroadcastSubscription._STATE_FIRING = 2; |
| 1274 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; |
| 1263 return _BroadcastSubscription; | 1275 return _BroadcastSubscription; |
| 1264 }); | 1276 }); |
| 1265 let _BroadcastSubscription = _BroadcastSubscription$(); | 1277 let _BroadcastSubscription = _BroadcastSubscription$(); |
| 1266 _BroadcastSubscription._STATE_EVENT_ID = 1; | |
| 1267 _BroadcastSubscription._STATE_FIRING = 2; | |
| 1268 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; | |
| 1269 const _addStreamState = Symbol('_addStreamState'); | 1278 const _addStreamState = Symbol('_addStreamState'); |
| 1270 const _doneFuture = Symbol('_doneFuture'); | 1279 const _doneFuture = Symbol('_doneFuture'); |
| 1271 const _isEmpty = Symbol('_isEmpty'); | 1280 const _isEmpty = Symbol('_isEmpty'); |
| 1272 const _hasOneListener = Symbol('_hasOneListener'); | 1281 const _hasOneListener = Symbol('_hasOneListener'); |
| 1273 const _isAddingStream = Symbol('_isAddingStream'); | 1282 const _isAddingStream = Symbol('_isAddingStream'); |
| 1274 const _mayAddEvent = Symbol('_mayAddEvent'); | 1283 const _mayAddEvent = Symbol('_mayAddEvent'); |
| 1275 const _ensureDoneFuture = Symbol('_ensureDoneFuture'); | 1284 const _ensureDoneFuture = Symbol('_ensureDoneFuture'); |
| 1276 const _addListener = Symbol('_addListener'); | 1285 const _addListener = Symbol('_addListener'); |
| 1277 const _removeListener = Symbol('_removeListener'); | 1286 const _removeListener = Symbol('_removeListener'); |
| 1278 const _callOnCancel = Symbol('_callOnCancel'); | 1287 const _callOnCancel = Symbol('_callOnCancel'); |
| (...skipping 215 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1494 addError: [dart.void, [core.Object], [core.StackTrace]], | 1503 addError: [dart.void, [core.Object], [core.StackTrace]], |
| 1495 close: [Future, []], | 1504 close: [Future, []], |
| 1496 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}], | 1505 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}], |
| 1497 [_add]: [dart.void, [T]], | 1506 [_add]: [dart.void, [T]], |
| 1498 [_addError]: [dart.void, [core.Object, core.StackTrace]], | 1507 [_addError]: [dart.void, [core.Object, core.StackTrace]], |
| 1499 [_close]: [dart.void, []], | 1508 [_close]: [dart.void, []], |
| 1500 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin
gStreamSubscription$(T)])]], | 1509 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin
gStreamSubscription$(T)])]], |
| 1501 [_callOnCancel]: [dart.void, []] | 1510 [_callOnCancel]: [dart.void, []] |
| 1502 }) | 1511 }) |
| 1503 }); | 1512 }); |
| 1513 _BroadcastStreamController._STATE_INITIAL = 0; |
| 1514 _BroadcastStreamController._STATE_EVENT_ID = 1; |
| 1515 _BroadcastStreamController._STATE_FIRING = 2; |
| 1516 _BroadcastStreamController._STATE_CLOSED = 4; |
| 1517 _BroadcastStreamController._STATE_ADDSTREAM = 8; |
| 1504 return _BroadcastStreamController; | 1518 return _BroadcastStreamController; |
| 1505 }); | 1519 }); |
| 1506 let _BroadcastStreamController = _BroadcastStreamController$(); | 1520 let _BroadcastStreamController = _BroadcastStreamController$(); |
| 1507 _BroadcastStreamController._STATE_INITIAL = 0; | |
| 1508 _BroadcastStreamController._STATE_EVENT_ID = 1; | |
| 1509 _BroadcastStreamController._STATE_FIRING = 2; | |
| 1510 _BroadcastStreamController._STATE_CLOSED = 4; | |
| 1511 _BroadcastStreamController._STATE_ADDSTREAM = 8; | |
| 1512 const _SyncBroadcastStreamController$ = dart.generic(function(T) { | 1521 const _SyncBroadcastStreamController$ = dart.generic(function(T) { |
| 1513 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T)
{ | 1522 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T)
{ |
| 1514 _SyncBroadcastStreamController(onListen, onCancel) { | 1523 _SyncBroadcastStreamController(onListen, onCancel) { |
| 1515 super._BroadcastStreamController(onListen, onCancel); | 1524 super._BroadcastStreamController(onListen, onCancel); |
| 1516 } | 1525 } |
| 1517 [_sendData](data) { | 1526 [_sendData](data) { |
| 1518 dart.as(data, T); | 1527 dart.as(data, T); |
| 1519 if (dart.notNull(this[_isEmpty])) return; | 1528 if (dart.notNull(this[_isEmpty])) return; |
| 1520 if (dart.notNull(this[_hasOneListener])) { | 1529 if (dart.notNull(this[_hasOneListener])) { |
| 1521 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr
eamController._STATE_FIRING); | 1530 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr
eamController._STATE_FIRING); |
| (...skipping 400 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1922 error: [Future$(T), [core.Object], [core.StackTrace]], | 1931 error: [Future$(T), [core.Object], [core.StackTrace]], |
| 1923 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] | 1932 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] |
| 1924 }), | 1933 }), |
| 1925 statics: () => ({ | 1934 statics: () => ({ |
| 1926 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor
e.bool, cleanUp: dart.functionType(dart.void, [dart.dynamic])}], | 1935 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor
e.bool, cleanUp: dart.functionType(dart.void, [dart.dynamic])}], |
| 1927 forEach: [Future$(), [core.Iterable, dart.functionType(dart.dynamic, [da
rt.dynamic])]], | 1936 forEach: [Future$(), [core.Iterable, dart.functionType(dart.dynamic, [da
rt.dynamic])]], |
| 1928 doWhile: [Future$(), [dart.functionType(dart.dynamic, [])]] | 1937 doWhile: [Future$(), [dart.functionType(dart.dynamic, [])]] |
| 1929 }), | 1938 }), |
| 1930 names: ['wait', 'forEach', 'doWhile'] | 1939 names: ['wait', 'forEach', 'doWhile'] |
| 1931 }); | 1940 }); |
| 1941 dart.defineLazyProperties(Future, { |
| 1942 get _nullFuture() { |
| 1943 return new _Future.immediate(null); |
| 1944 } |
| 1945 }); |
| 1932 return Future; | 1946 return Future; |
| 1933 }); | 1947 }); |
| 1934 let Future = Future$(); | 1948 let Future = Future$(); |
| 1935 dart.defineLazyProperties(Future, { | |
| 1936 get _nullFuture() { | |
| 1937 return new _Future.immediate(null); | |
| 1938 } | |
| 1939 }); | |
| 1940 class TimeoutException extends core.Object { | 1949 class TimeoutException extends core.Object { |
| 1941 TimeoutException(message, duration) { | 1950 TimeoutException(message, duration) { |
| 1942 if (duration === void 0) duration = null; | 1951 if (duration === void 0) duration = null; |
| 1943 this.message = message; | 1952 this.message = message; |
| 1944 this.duration = duration; | 1953 this.duration = duration; |
| 1945 } | 1954 } |
| 1946 toString() { | 1955 toString() { |
| 1947 let result = "TimeoutException"; | 1956 let result = "TimeoutException"; |
| 1948 if (this.duration != null) result = `TimeoutException after ${this.duratio
n}`; | 1957 if (this.duration != null) result = `TimeoutException after ${this.duratio
n}`; |
| 1949 if (this.message != null) result = `${result}: ${this.message}`; | 1958 if (this.message != null) result = `${result}: ${this.message}`; |
| (...skipping 191 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2141 catchError: [_FutureListener, [_Future, core.Function, _FutureErrorTest]], | 2150 catchError: [_FutureListener, [_Future, core.Function, _FutureErrorTest]], |
| 2142 whenComplete: [_FutureListener, [_Future, _FutureAction]], | 2151 whenComplete: [_FutureListener, [_Future, _FutureAction]], |
| 2143 chain: [_FutureListener, [_Future]] | 2152 chain: [_FutureListener, [_Future]] |
| 2144 }) | 2153 }) |
| 2145 }); | 2154 }); |
| 2146 _FutureListener.MASK_VALUE = 1; | 2155 _FutureListener.MASK_VALUE = 1; |
| 2147 _FutureListener.MASK_ERROR = 2; | 2156 _FutureListener.MASK_ERROR = 2; |
| 2148 _FutureListener.MASK_TEST_ERROR = 4; | 2157 _FutureListener.MASK_TEST_ERROR = 4; |
| 2149 _FutureListener.MASK_WHENCOMPLETE = 8; | 2158 _FutureListener.MASK_WHENCOMPLETE = 8; |
| 2150 _FutureListener.STATE_CHAIN = 0; | 2159 _FutureListener.STATE_CHAIN = 0; |
| 2151 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE; | 2160 dart.defineLazyProperties(_FutureListener, { |
| 2152 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE)
| dart.notNull(_FutureListener.MASK_ERROR); | 2161 get STATE_THEN() { |
| 2153 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR; | 2162 return _FutureListener.MASK_VALUE; |
| 2154 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO
R) | dart.notNull(_FutureListener.MASK_TEST_ERROR); | 2163 }, |
| 2155 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE; | 2164 get STATE_THEN_ONERROR() { |
| 2165 return dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureList
ener.MASK_ERROR); |
| 2166 }, |
| 2167 get STATE_CATCHERROR() { |
| 2168 return _FutureListener.MASK_ERROR; |
| 2169 }, |
| 2170 get STATE_CATCHERROR_TEST() { |
| 2171 return dart.notNull(_FutureListener.MASK_ERROR) | dart.notNull(_FutureList
ener.MASK_TEST_ERROR); |
| 2172 }, |
| 2173 get STATE_WHENCOMPLETE() { |
| 2174 return _FutureListener.MASK_WHENCOMPLETE; |
| 2175 } |
| 2176 }); |
| 2156 const _resultOrListeners = Symbol('_resultOrListeners'); | 2177 const _resultOrListeners = Symbol('_resultOrListeners'); |
| 2157 const _isChained = Symbol('_isChained'); | 2178 const _isChained = Symbol('_isChained'); |
| 2158 const _isComplete = Symbol('_isComplete'); | 2179 const _isComplete = Symbol('_isComplete'); |
| 2159 const _hasValue = Symbol('_hasValue'); | 2180 const _hasValue = Symbol('_hasValue'); |
| 2160 const _hasError = Symbol('_hasError'); | 2181 const _hasError = Symbol('_hasError'); |
| 2161 const _markPendingCompletion = Symbol('_markPendingCompletion'); | 2182 const _markPendingCompletion = Symbol('_markPendingCompletion'); |
| 2162 const _value = Symbol('_value'); | 2183 const _value = Symbol('_value'); |
| 2163 const _error = Symbol('_error'); | 2184 const _error = Symbol('_error'); |
| 2164 const _setValue = Symbol('_setValue'); | 2185 const _setValue = Symbol('_setValue'); |
| 2165 const _setErrorObject = Symbol('_setErrorObject'); | 2186 const _setErrorObject = Symbol('_setErrorObject'); |
| (...skipping 435 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2601 [_asyncCompleteError]: [dart.void, [dart.dynamic, core.StackTrace]], | 2622 [_asyncCompleteError]: [dart.void, [dart.dynamic, core.StackTrace]], |
| 2602 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(dart.dy
namic, [])}] | 2623 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(dart.dy
namic, [])}] |
| 2603 }), | 2624 }), |
| 2604 statics: () => ({ | 2625 statics: () => ({ |
| 2605 _chainForeignFuture: [dart.void, [Future, _Future$()]], | 2626 _chainForeignFuture: [dart.void, [Future, _Future$()]], |
| 2606 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], | 2627 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], |
| 2607 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] | 2628 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] |
| 2608 }), | 2629 }), |
| 2609 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] | 2630 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] |
| 2610 }); | 2631 }); |
| 2632 _Future._INCOMPLETE = 0; |
| 2633 _Future._PENDING_COMPLETE = 1; |
| 2634 _Future._CHAINED = 2; |
| 2635 _Future._VALUE = 4; |
| 2636 _Future._ERROR = 8; |
| 2611 return _Future; | 2637 return _Future; |
| 2612 }); | 2638 }); |
| 2613 let _Future = _Future$(); | 2639 let _Future = _Future$(); |
| 2614 _Future._INCOMPLETE = 0; | |
| 2615 _Future._PENDING_COMPLETE = 1; | |
| 2616 _Future._CHAINED = 2; | |
| 2617 _Future._VALUE = 4; | |
| 2618 _Future._ERROR = 8; | |
| 2619 const __CastType6$ = dart.generic(function(T, S) { | 2640 const __CastType6$ = dart.generic(function(T, S) { |
| 2620 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [
T])); | 2641 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [
T])); |
| 2621 return __CastType6; | 2642 return __CastType6; |
| 2622 }); | 2643 }); |
| 2623 let __CastType6 = __CastType6$(); | 2644 let __CastType6 = __CastType6$(); |
| 2624 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.b
ool, [dart.dynamic])); | 2645 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.b
ool, [dart.dynamic])); |
| 2625 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart
.dynamic, [dart.dynamic])); | 2646 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart
.dynamic, [dart.dynamic])); |
| 2626 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(
dart.void, [])); | 2647 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(
dart.void, [])); |
| 2627 class _AsyncCallbackEntry extends core.Object { | 2648 class _AsyncCallbackEntry extends core.Object { |
| 2628 _AsyncCallbackEntry(callback) { | 2649 _AsyncCallbackEntry(callback) { |
| (...skipping 549 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3178 [_closeUnchecked]: [dart.void, []], | 3199 [_closeUnchecked]: [dart.void, []], |
| 3179 [_add]: [dart.void, [T]], | 3200 [_add]: [dart.void, [T]], |
| 3180 [_addError]: [dart.void, [core.Object, core.StackTrace]], | 3201 [_addError]: [dart.void, [core.Object, core.StackTrace]], |
| 3181 [_close]: [dart.void, []], | 3202 [_close]: [dart.void, []], |
| 3182 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T]
), core.Function, dart.functionType(dart.void, []), core.bool]], | 3203 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T]
), core.Function, dart.functionType(dart.void, []), core.bool]], |
| 3183 [_recordCancel]: [Future, [StreamSubscription$(T)]], | 3204 [_recordCancel]: [Future, [StreamSubscription$(T)]], |
| 3184 [_recordPause]: [dart.void, [StreamSubscription$(T)]], | 3205 [_recordPause]: [dart.void, [StreamSubscription$(T)]], |
| 3185 [_recordResume]: [dart.void, [StreamSubscription$(T)]] | 3206 [_recordResume]: [dart.void, [StreamSubscription$(T)]] |
| 3186 }) | 3207 }) |
| 3187 }); | 3208 }); |
| 3209 _StreamController._STATE_INITIAL = 0; |
| 3210 _StreamController._STATE_SUBSCRIBED = 1; |
| 3211 _StreamController._STATE_CANCELED = 2; |
| 3212 _StreamController._STATE_SUBSCRIPTION_MASK = 3; |
| 3213 _StreamController._STATE_CLOSED = 4; |
| 3214 _StreamController._STATE_ADDSTREAM = 8; |
| 3188 return _StreamController; | 3215 return _StreamController; |
| 3189 }); | 3216 }); |
| 3190 let _StreamController = _StreamController$(); | 3217 let _StreamController = _StreamController$(); |
| 3191 _StreamController._STATE_INITIAL = 0; | |
| 3192 _StreamController._STATE_SUBSCRIBED = 1; | |
| 3193 _StreamController._STATE_CANCELED = 2; | |
| 3194 _StreamController._STATE_SUBSCRIPTION_MASK = 3; | |
| 3195 _StreamController._STATE_CLOSED = 4; | |
| 3196 _StreamController._STATE_ADDSTREAM = 8; | |
| 3197 const _SyncStreamControllerDispatch$ = dart.generic(function(T) { | 3218 const _SyncStreamControllerDispatch$ = dart.generic(function(T) { |
| 3198 class _SyncStreamControllerDispatch extends core.Object { | 3219 class _SyncStreamControllerDispatch extends core.Object { |
| 3199 [_sendData](data) { | 3220 [_sendData](data) { |
| 3200 dart.as(data, T); | 3221 dart.as(data, T); |
| 3201 this[_subscription][_add](data); | 3222 this[_subscription][_add](data); |
| 3202 } | 3223 } |
| 3203 [_sendError](error, stackTrace) { | 3224 [_sendError](error, stackTrace) { |
| 3204 this[_subscription][_addError](error, stackTrace); | 3225 this[_subscription][_addError](error, stackTrace); |
| 3205 } | 3226 } |
| 3206 [_sendDone]() { | 3227 [_sendDone]() { |
| (...skipping 217 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3424 const _EventSink$ = dart.generic(function(T) { | 3445 const _EventSink$ = dart.generic(function(T) { |
| 3425 class _EventSink extends core.Object {} | 3446 class _EventSink extends core.Object {} |
| 3426 return _EventSink; | 3447 return _EventSink; |
| 3427 }); | 3448 }); |
| 3428 let _EventSink = _EventSink$(); | 3449 let _EventSink = _EventSink$(); |
| 3429 const _EventDispatch$ = dart.generic(function(T) { | 3450 const _EventDispatch$ = dart.generic(function(T) { |
| 3430 class _EventDispatch extends core.Object {} | 3451 class _EventDispatch extends core.Object {} |
| 3431 return _EventDispatch; | 3452 return _EventDispatch; |
| 3432 }); | 3453 }); |
| 3433 let _EventDispatch = _EventDispatch$(); | 3454 let _EventDispatch = _EventDispatch$(); |
| 3434 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; | |
| 3435 _BufferingStreamSubscription._STATE_CLOSED = 2; | |
| 3436 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; | |
| 3437 _BufferingStreamSubscription._STATE_CANCELED = 8; | |
| 3438 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; | |
| 3439 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; | |
| 3440 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; | |
| 3441 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; | |
| 3442 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; | |
| 3443 const _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionTyp
e(_PendingEvents, [])); | 3455 const _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionTyp
e(_PendingEvents, [])); |
| 3444 const _isUsed = Symbol('_isUsed'); | 3456 const _isUsed = Symbol('_isUsed'); |
| 3445 const _GeneratedStreamImpl$ = dart.generic(function(T) { | 3457 const _GeneratedStreamImpl$ = dart.generic(function(T) { |
| 3446 class _GeneratedStreamImpl extends _StreamImpl$(T) { | 3458 class _GeneratedStreamImpl extends _StreamImpl$(T) { |
| 3447 _GeneratedStreamImpl(pending) { | 3459 _GeneratedStreamImpl(pending) { |
| 3448 this[_pending] = pending; | 3460 this[_pending] = pending; |
| 3449 this[_isUsed] = false; | 3461 this[_isUsed] = false; |
| 3450 } | 3462 } |
| 3451 [_createSubscription](onData, onError, onDone, cancelOnError) { | 3463 [_createSubscription](onData, onError, onDone, cancelOnError) { |
| 3452 dart.as(onData, dart.functionType(dart.void, [T])); | 3464 dart.as(onData, dart.functionType(dart.void, [T])); |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3495 cancelSchedule() { | 3507 cancelSchedule() { |
| 3496 if (dart.notNull(this.isScheduled)) this[_state] = _PendingEvents._STATE_C
ANCELED; | 3508 if (dart.notNull(this.isScheduled)) this[_state] = _PendingEvents._STATE_C
ANCELED; |
| 3497 } | 3509 } |
| 3498 } | 3510 } |
| 3499 dart.setSignature(_PendingEvents, { | 3511 dart.setSignature(_PendingEvents, { |
| 3500 methods: () => ({ | 3512 methods: () => ({ |
| 3501 schedule: [dart.void, [_EventDispatch]], | 3513 schedule: [dart.void, [_EventDispatch]], |
| 3502 cancelSchedule: [dart.void, []] | 3514 cancelSchedule: [dart.void, []] |
| 3503 }) | 3515 }) |
| 3504 }); | 3516 }); |
| 3517 _PendingEvents._STATE_UNSCHEDULED = 0; |
| 3518 _PendingEvents._STATE_SCHEDULED = 1; |
| 3519 _PendingEvents._STATE_CANCELED = 3; |
| 3505 const _iterator = Symbol('_iterator'); | 3520 const _iterator = Symbol('_iterator'); |
| 3506 const _IterablePendingEvents$ = dart.generic(function(T) { | 3521 const _IterablePendingEvents$ = dart.generic(function(T) { |
| 3507 class _IterablePendingEvents extends _PendingEvents { | 3522 class _IterablePendingEvents extends _PendingEvents { |
| 3508 _IterablePendingEvents(data) { | 3523 _IterablePendingEvents(data) { |
| 3509 this[_iterator] = data[dartx.iterator]; | 3524 this[_iterator] = data[dartx.iterator]; |
| 3510 super._PendingEvents(); | 3525 super._PendingEvents(); |
| 3511 } | 3526 } |
| 3512 get isEmpty() { | 3527 get isEmpty() { |
| 3513 return this[_iterator] == null; | 3528 return this[_iterator] == null; |
| 3514 } | 3529 } |
| (...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3617 } | 3632 } |
| 3618 set next(_) { | 3633 set next(_) { |
| 3619 dart.throw(new core.StateError("No events after a done.")); | 3634 dart.throw(new core.StateError("No events after a done.")); |
| 3620 } | 3635 } |
| 3621 } | 3636 } |
| 3622 _DelayedDone[dart.implements] = () => [_DelayedEvent]; | 3637 _DelayedDone[dart.implements] = () => [_DelayedEvent]; |
| 3623 dart.setSignature(_DelayedDone, { | 3638 dart.setSignature(_DelayedDone, { |
| 3624 constructors: () => ({_DelayedDone: [_DelayedDone, []]}), | 3639 constructors: () => ({_DelayedDone: [_DelayedDone, []]}), |
| 3625 methods: () => ({perform: [dart.void, [_EventDispatch]]}) | 3640 methods: () => ({perform: [dart.void, [_EventDispatch]]}) |
| 3626 }); | 3641 }); |
| 3627 _PendingEvents._STATE_UNSCHEDULED = 0; | |
| 3628 _PendingEvents._STATE_SCHEDULED = 1; | |
| 3629 _PendingEvents._STATE_CANCELED = 3; | |
| 3630 class _StreamImplEvents extends _PendingEvents { | 3642 class _StreamImplEvents extends _PendingEvents { |
| 3631 _StreamImplEvents() { | 3643 _StreamImplEvents() { |
| 3632 this.firstPendingEvent = null; | 3644 this.firstPendingEvent = null; |
| 3633 this.lastPendingEvent = null; | 3645 this.lastPendingEvent = null; |
| 3634 super._PendingEvents(); | 3646 super._PendingEvents(); |
| 3635 } | 3647 } |
| 3636 get isEmpty() { | 3648 get isEmpty() { |
| 3637 return this.lastPendingEvent == null; | 3649 return this.lastPendingEvent == null; |
| 3638 } | 3650 } |
| 3639 add(event) { | 3651 add(event) { |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3763 onData: [dart.void, [dart.functionType(dart.void, [T])]], | 3775 onData: [dart.void, [dart.functionType(dart.void, [T])]], |
| 3764 onError: [dart.void, [core.Function]], | 3776 onError: [dart.void, [core.Function]], |
| 3765 onDone: [dart.void, [dart.functionType(dart.void, [])]], | 3777 onDone: [dart.void, [dart.functionType(dart.void, [])]], |
| 3766 pause: [dart.void, [], [Future]], | 3778 pause: [dart.void, [], [Future]], |
| 3767 resume: [dart.void, []], | 3779 resume: [dart.void, []], |
| 3768 cancel: [Future, []], | 3780 cancel: [Future, []], |
| 3769 asFuture: [Future, [], [dart.dynamic]], | 3781 asFuture: [Future, [], [dart.dynamic]], |
| 3770 [_sendDone]: [dart.void, []] | 3782 [_sendDone]: [dart.void, []] |
| 3771 }) | 3783 }) |
| 3772 }); | 3784 }); |
| 3785 _DoneStreamSubscription._DONE_SENT = 1; |
| 3786 _DoneStreamSubscription._SCHEDULED = 2; |
| 3787 _DoneStreamSubscription._PAUSED = 4; |
| 3773 return _DoneStreamSubscription; | 3788 return _DoneStreamSubscription; |
| 3774 }); | 3789 }); |
| 3775 let _DoneStreamSubscription = _DoneStreamSubscription$(); | 3790 let _DoneStreamSubscription = _DoneStreamSubscription$(); |
| 3776 _DoneStreamSubscription._DONE_SENT = 1; | |
| 3777 _DoneStreamSubscription._SCHEDULED = 2; | |
| 3778 _DoneStreamSubscription._PAUSED = 4; | |
| 3779 const _source = Symbol('_source'); | 3791 const _source = Symbol('_source'); |
| 3780 const _onListenHandler = Symbol('_onListenHandler'); | 3792 const _onListenHandler = Symbol('_onListenHandler'); |
| 3781 const _onCancelHandler = Symbol('_onCancelHandler'); | 3793 const _onCancelHandler = Symbol('_onCancelHandler'); |
| 3782 const _cancelSubscription = Symbol('_cancelSubscription'); | 3794 const _cancelSubscription = Symbol('_cancelSubscription'); |
| 3783 const _pauseSubscription = Symbol('_pauseSubscription'); | 3795 const _pauseSubscription = Symbol('_pauseSubscription'); |
| 3784 const _resumeSubscription = Symbol('_resumeSubscription'); | 3796 const _resumeSubscription = Symbol('_resumeSubscription'); |
| 3785 const _isSubscriptionPaused = Symbol('_isSubscriptionPaused'); | 3797 const _isSubscriptionPaused = Symbol('_isSubscriptionPaused'); |
| 3786 const _AsBroadcastStream$ = dart.generic(function(T) { | 3798 const _AsBroadcastStream$ = dart.generic(function(T) { |
| 3787 class _AsBroadcastStream extends Stream$(T) { | 3799 class _AsBroadcastStream extends Stream$(T) { |
| 3788 _AsBroadcastStream(source, onListenHandler, onCancelHandler) { | 3800 _AsBroadcastStream(source, onListenHandler, onCancelHandler) { |
| (...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4030 constructors: () => ({_StreamIteratorImpl: [_StreamIteratorImpl$(T), [Stre
am$(T)]]}), | 4042 constructors: () => ({_StreamIteratorImpl: [_StreamIteratorImpl$(T), [Stre
am$(T)]]}), |
| 4031 methods: () => ({ | 4043 methods: () => ({ |
| 4032 moveNext: [Future$(core.bool), []], | 4044 moveNext: [Future$(core.bool), []], |
| 4033 [_clear]: [dart.void, []], | 4045 [_clear]: [dart.void, []], |
| 4034 cancel: [Future, []], | 4046 cancel: [Future, []], |
| 4035 [_onData]: [dart.void, [T]], | 4047 [_onData]: [dart.void, [T]], |
| 4036 [_onError]: [dart.void, [core.Object], [core.StackTrace]], | 4048 [_onError]: [dart.void, [core.Object], [core.StackTrace]], |
| 4037 [_onDone]: [dart.void, []] | 4049 [_onDone]: [dart.void, []] |
| 4038 }) | 4050 }) |
| 4039 }); | 4051 }); |
| 4052 _StreamIteratorImpl._STATE_FOUND = 0; |
| 4053 _StreamIteratorImpl._STATE_DONE = 1; |
| 4054 _StreamIteratorImpl._STATE_MOVING = 2; |
| 4055 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
| 4056 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
| 4057 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
| 4040 return _StreamIteratorImpl; | 4058 return _StreamIteratorImpl; |
| 4041 }); | 4059 }); |
| 4042 let _StreamIteratorImpl = _StreamIteratorImpl$(); | 4060 let _StreamIteratorImpl = _StreamIteratorImpl$(); |
| 4043 _StreamIteratorImpl._STATE_FOUND = 0; | |
| 4044 _StreamIteratorImpl._STATE_DONE = 1; | |
| 4045 _StreamIteratorImpl._STATE_MOVING = 2; | |
| 4046 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | |
| 4047 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | |
| 4048 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | |
| 4049 const __CastType20$ = dart.generic(function(T) { | 4061 const __CastType20$ = dart.generic(function(T) { |
| 4050 const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(da
rt.void, [T])); | 4062 const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(da
rt.void, [T])); |
| 4051 return __CastType20; | 4063 return __CastType20; |
| 4052 }); | 4064 }); |
| 4053 let __CastType20 = __CastType20$(); | 4065 let __CastType20 = __CastType20$(); |
| 4054 const __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])); | 4066 const __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])); |
| 4055 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart
.dynamic, [dart.dynamic])); | 4067 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart
.dynamic, [dart.dynamic])); |
| 4056 function _runUserCode(userCode, onSuccess, onError) { | 4068 function _runUserCode(userCode, onSuccess, onError) { |
| 4057 try { | 4069 try { |
| 4058 dart.dcall(onSuccess, userCode()); | 4070 dart.dcall(onSuccess, userCode()); |
| (...skipping 464 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4523 sink[_add](inputEvent); | 4535 sink[_add](inputEvent); |
| 4524 this[_previous] = inputEvent; | 4536 this[_previous] = inputEvent; |
| 4525 } | 4537 } |
| 4526 } | 4538 } |
| 4527 } | 4539 } |
| 4528 } | 4540 } |
| 4529 dart.setSignature(_DistinctStream, { | 4541 dart.setSignature(_DistinctStream, { |
| 4530 constructors: () => ({_DistinctStream: [_DistinctStream$(T), [Stream$(T),
dart.functionType(core.bool, [T, T])]]}), | 4542 constructors: () => ({_DistinctStream: [_DistinctStream$(T), [Stream$(T),
dart.functionType(core.bool, [T, T])]]}), |
| 4531 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) | 4543 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) |
| 4532 }); | 4544 }); |
| 4545 dart.defineLazyProperties(_DistinctStream, { |
| 4546 get _SENTINEL() { |
| 4547 return new core.Object(); |
| 4548 }, |
| 4549 set _SENTINEL(_) {} |
| 4550 }); |
| 4533 return _DistinctStream; | 4551 return _DistinctStream; |
| 4534 }); | 4552 }); |
| 4535 let _DistinctStream = _DistinctStream$(); | 4553 let _DistinctStream = _DistinctStream$(); |
| 4536 dart.defineLazyProperties(_DistinctStream, { | |
| 4537 get _SENTINEL() { | |
| 4538 return new core.Object(); | |
| 4539 }, | |
| 4540 set _SENTINEL(_) {} | |
| 4541 }); | |
| 4542 const _EventSinkWrapper$ = dart.generic(function(T) { | 4554 const _EventSinkWrapper$ = dart.generic(function(T) { |
| 4543 class _EventSinkWrapper extends core.Object { | 4555 class _EventSinkWrapper extends core.Object { |
| 4544 _EventSinkWrapper(sink) { | 4556 _EventSinkWrapper(sink) { |
| 4545 this[_sink] = sink; | 4557 this[_sink] = sink; |
| 4546 } | 4558 } |
| 4547 add(data) { | 4559 add(data) { |
| 4548 dart.as(data, T); | 4560 dart.as(data, T); |
| 4549 this[_sink][_add](data); | 4561 this[_sink][_add](data); |
| 4550 } | 4562 } |
| 4551 addError(error, stackTrace) { | 4563 addError(error, stackTrace) { |
| (...skipping 460 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5012 } | 5024 } |
| 5013 dart.defineNamedConstructor(Zone, '_'); | 5025 dart.defineNamedConstructor(Zone, '_'); |
| 5014 dart.setSignature(Zone, { | 5026 dart.setSignature(Zone, { |
| 5015 constructors: () => ({_: [Zone, []]}), | 5027 constructors: () => ({_: [Zone, []]}), |
| 5016 statics: () => ({ | 5028 statics: () => ({ |
| 5017 _enter: [Zone, [Zone]], | 5029 _enter: [Zone, [Zone]], |
| 5018 _leave: [dart.void, [Zone]] | 5030 _leave: [dart.void, [Zone]] |
| 5019 }), | 5031 }), |
| 5020 names: ['_enter', '_leave'] | 5032 names: ['_enter', '_leave'] |
| 5021 }); | 5033 }); |
| 5022 class _Zone extends core.Object { | 5034 dart.defineLazyProperties(Zone, { |
| 5023 _Zone() { | 5035 get ROOT() { |
| 5024 } | 5036 return _ROOT_ZONE; |
| 5025 inSameErrorZone(otherZone) { | 5037 }, |
| 5026 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); | 5038 get _current() { |
| 5027 } | 5039 return _ROOT_ZONE; |
| 5040 }, |
| 5041 set _current(_) {} |
| 5042 }); |
| 5043 const _delegate = Symbol('_delegate'); |
| 5044 function _parentDelegate(zone) { |
| 5045 if (zone.parent == null) return null; |
| 5046 return zone.parent[_delegate]; |
| 5028 } | 5047 } |
| 5029 _Zone[dart.implements] = () => [Zone]; | 5048 dart.fn(_parentDelegate, () => dart.definiteFunctionType(ZoneDelegate, [_Zone]
)); |
| 5030 dart.setSignature(_Zone, { | 5049 const _delegationTarget = Symbol('_delegationTarget'); |
| 5031 constructors: () => ({_Zone: [_Zone, []]}), | 5050 const _handleUncaughtError = Symbol('_handleUncaughtError'); |
| 5032 methods: () => ({inSameErrorZone: [core.bool, [Zone]]}) | |
| 5033 }); | |
| 5034 const _run = Symbol('_run'); | 5051 const _run = Symbol('_run'); |
| 5035 const _runUnary = Symbol('_runUnary'); | 5052 const _runUnary = Symbol('_runUnary'); |
| 5036 const _runBinary = Symbol('_runBinary'); | 5053 const _runBinary = Symbol('_runBinary'); |
| 5037 const _registerCallback = Symbol('_registerCallback'); | 5054 const _registerCallback = Symbol('_registerCallback'); |
| 5038 const _registerUnaryCallback = Symbol('_registerUnaryCallback'); | 5055 const _registerUnaryCallback = Symbol('_registerUnaryCallback'); |
| 5039 const _registerBinaryCallback = Symbol('_registerBinaryCallback'); | 5056 const _registerBinaryCallback = Symbol('_registerBinaryCallback'); |
| 5040 const _errorCallback = Symbol('_errorCallback'); | 5057 const _errorCallback = Symbol('_errorCallback'); |
| 5041 const _scheduleMicrotask = Symbol('_scheduleMicrotask'); | 5058 const _scheduleMicrotask = Symbol('_scheduleMicrotask'); |
| 5042 const _createTimer = Symbol('_createTimer'); | 5059 const _createTimer = Symbol('_createTimer'); |
| 5043 const _createPeriodicTimer = Symbol('_createPeriodicTimer'); | 5060 const _createPeriodicTimer = Symbol('_createPeriodicTimer'); |
| 5044 const _print = Symbol('_print'); | 5061 const _print = Symbol('_print'); |
| 5045 const _fork = Symbol('_fork'); | 5062 const _fork = Symbol('_fork'); |
| 5046 const _handleUncaughtError = Symbol('_handleUncaughtError'); | |
| 5047 const _map = Symbol('_map'); | |
| 5048 const _delegate = Symbol('_delegate'); | |
| 5049 class _RootZone extends _Zone { | |
| 5050 _RootZone() { | |
| 5051 super._Zone(); | |
| 5052 } | |
| 5053 get [_run]() { | |
| 5054 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun)); | |
| 5055 } | |
| 5056 get [_runUnary]() { | |
| 5057 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary)); | |
| 5058 } | |
| 5059 get [_runBinary]() { | |
| 5060 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary)); | |
| 5061 } | |
| 5062 get [_registerCallback]() { | |
| 5063 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback)); | |
| 5064 } | |
| 5065 get [_registerUnaryCallback]() { | |
| 5066 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback
)); | |
| 5067 } | |
| 5068 get [_registerBinaryCallback]() { | |
| 5069 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallbac
k)); | |
| 5070 } | |
| 5071 get [_errorCallback]() { | |
| 5072 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback)); | |
| 5073 } | |
| 5074 get [_scheduleMicrotask]() { | |
| 5075 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask)); | |
| 5076 } | |
| 5077 get [_createTimer]() { | |
| 5078 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer)); | |
| 5079 } | |
| 5080 get [_createPeriodicTimer]() { | |
| 5081 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer))
; | |
| 5082 } | |
| 5083 get [_print]() { | |
| 5084 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint)); | |
| 5085 } | |
| 5086 get [_fork]() { | |
| 5087 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork)); | |
| 5088 } | |
| 5089 get [_handleUncaughtError]() { | |
| 5090 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError))
; | |
| 5091 } | |
| 5092 get parent() { | |
| 5093 return null; | |
| 5094 } | |
| 5095 get [_map]() { | |
| 5096 return _RootZone._rootMap; | |
| 5097 } | |
| 5098 get [_delegate]() { | |
| 5099 if (_RootZone._rootDelegate != null) return _RootZone._rootDelegate; | |
| 5100 return _RootZone._rootDelegate = new _ZoneDelegate(this); | |
| 5101 } | |
| 5102 get errorZone() { | |
| 5103 return this; | |
| 5104 } | |
| 5105 runGuarded(f) { | |
| 5106 try { | |
| 5107 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) { | |
| 5108 return f(); | |
| 5109 } | |
| 5110 return _rootRun(null, null, this, f); | |
| 5111 } catch (e) { | |
| 5112 let s = dart.stackTrace(e); | |
| 5113 return this.handleUncaughtError(e, s); | |
| 5114 } | |
| 5115 | |
| 5116 } | |
| 5117 runUnaryGuarded(f, arg) { | |
| 5118 try { | |
| 5119 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) { | |
| 5120 return dart.dcall(f, arg); | |
| 5121 } | |
| 5122 return _rootRunUnary(null, null, this, f, arg); | |
| 5123 } catch (e) { | |
| 5124 let s = dart.stackTrace(e); | |
| 5125 return this.handleUncaughtError(e, s); | |
| 5126 } | |
| 5127 | |
| 5128 } | |
| 5129 runBinaryGuarded(f, arg1, arg2) { | |
| 5130 try { | |
| 5131 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) { | |
| 5132 return dart.dcall(f, arg1, arg2); | |
| 5133 } | |
| 5134 return _rootRunBinary(null, null, this, f, arg1, arg2); | |
| 5135 } catch (e) { | |
| 5136 let s = dart.stackTrace(e); | |
| 5137 return this.handleUncaughtError(e, s); | |
| 5138 } | |
| 5139 | |
| 5140 } | |
| 5141 bindCallback(f, opts) { | |
| 5142 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | |
| 5143 if (dart.notNull(runGuarded)) { | |
| 5144 return dart.fn((() => this.runGuarded(f)).bind(this)); | |
| 5145 } else { | |
| 5146 return dart.fn((() => this.run(f)).bind(this)); | |
| 5147 } | |
| 5148 } | |
| 5149 bindUnaryCallback(f, opts) { | |
| 5150 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | |
| 5151 if (dart.notNull(runGuarded)) { | |
| 5152 return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this)); | |
| 5153 } else { | |
| 5154 return dart.fn((arg => this.runUnary(f, arg)).bind(this)); | |
| 5155 } | |
| 5156 } | |
| 5157 bindBinaryCallback(f, opts) { | |
| 5158 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | |
| 5159 if (dart.notNull(runGuarded)) { | |
| 5160 return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bi
nd(this)); | |
| 5161 } else { | |
| 5162 return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this
)); | |
| 5163 } | |
| 5164 } | |
| 5165 get(key) { | |
| 5166 return null; | |
| 5167 } | |
| 5168 handleUncaughtError(error, stackTrace) { | |
| 5169 return _rootHandleUncaughtError(null, null, this, error, stackTrace); | |
| 5170 } | |
| 5171 fork(opts) { | |
| 5172 let specification = opts && 'specification' in opts ? opts.specification :
null; | |
| 5173 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | |
| 5174 return _rootFork(null, null, this, specification, zoneValues); | |
| 5175 } | |
| 5176 run(f) { | |
| 5177 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return f(); | |
| 5178 return _rootRun(null, null, this, f); | |
| 5179 } | |
| 5180 runUnary(f, arg) { | |
| 5181 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d
call(f, arg); | |
| 5182 return _rootRunUnary(null, null, this, f, arg); | |
| 5183 } | |
| 5184 runBinary(f, arg1, arg2) { | |
| 5185 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d
call(f, arg1, arg2); | |
| 5186 return _rootRunBinary(null, null, this, f, arg1, arg2); | |
| 5187 } | |
| 5188 registerCallback(f) { | |
| 5189 return f; | |
| 5190 } | |
| 5191 registerUnaryCallback(f) { | |
| 5192 return f; | |
| 5193 } | |
| 5194 registerBinaryCallback(f) { | |
| 5195 return f; | |
| 5196 } | |
| 5197 errorCallback(error, stackTrace) { | |
| 5198 return null; | |
| 5199 } | |
| 5200 scheduleMicrotask(f) { | |
| 5201 _rootScheduleMicrotask(null, null, this, f); | |
| 5202 } | |
| 5203 createTimer(duration, f) { | |
| 5204 return Timer._createTimer(duration, f); | |
| 5205 } | |
| 5206 createPeriodicTimer(duration, f) { | |
| 5207 return Timer._createPeriodicTimer(duration, f); | |
| 5208 } | |
| 5209 print(line) { | |
| 5210 _internal.printToConsole(line); | |
| 5211 } | |
| 5212 } | |
| 5213 dart.setSignature(_RootZone, { | |
| 5214 constructors: () => ({_RootZone: [_RootZone, []]}), | |
| 5215 methods: () => ({ | |
| 5216 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], | |
| 5217 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn
amic]), dart.dynamic]], | |
| 5218 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy
namic, dart.dynamic]), dart.dynamic, dart.dynamic]], | |
| 5219 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGu
arded: core.bool}], | |
| 5220 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d
art.dynamic])], {runGuarded: core.bool}], | |
| 5221 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic,
[dart.dynamic, dart.dynamic])], {runGuarded: core.bool}], | |
| 5222 get: [dart.dynamic, [core.Object]], | |
| 5223 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]], | |
| 5224 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, | |
| 5225 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], | |
| 5226 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]),
dart.dynamic]], | |
| 5227 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic,
dart.dynamic]), dart.dynamic, dart.dynamic]], | |
| 5228 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]], | |
| 5229 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic
, [dart.dynamic])]], | |
| 5230 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam
ic, [dart.dynamic, dart.dynamic])]], | |
| 5231 errorCallback: [AsyncError, [core.Object, core.StackTrace]], | |
| 5232 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], | |
| 5233 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | |
| 5234 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], | |
| 5235 print: [dart.void, [core.String]] | |
| 5236 }) | |
| 5237 }); | |
| 5238 const _ROOT_ZONE = dart.const(new _RootZone()); | |
| 5239 Zone.ROOT = _ROOT_ZONE; | |
| 5240 Zone._current = _ROOT_ZONE; | |
| 5241 function _parentDelegate(zone) { | |
| 5242 if (zone.parent == null) return null; | |
| 5243 return zone.parent[_delegate]; | |
| 5244 } | |
| 5245 dart.fn(_parentDelegate, ZoneDelegate, [_Zone]); | |
| 5246 const _delegationTarget = Symbol('_delegationTarget'); | |
| 5247 class _ZoneDelegate extends core.Object { | 5063 class _ZoneDelegate extends core.Object { |
| 5248 _ZoneDelegate(delegationTarget) { | 5064 _ZoneDelegate(delegationTarget) { |
| 5249 this[_delegationTarget] = delegationTarget; | 5065 this[_delegationTarget] = delegationTarget; |
| 5250 } | 5066 } |
| 5251 handleUncaughtError(zone, error, stackTrace) { | 5067 handleUncaughtError(zone, error, stackTrace) { |
| 5252 let implementation = this[_delegationTarget][_handleUncaughtError]; | 5068 let implementation = this[_delegationTarget][_handleUncaughtError]; |
| 5253 let implZone = implementation.zone; | 5069 let implZone = implementation.zone; |
| 5254 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ
one), zone, error, stackTrace); | 5070 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ
one), zone, error, stackTrace); |
| 5255 } | 5071 } |
| 5256 run(zone, f) { | 5072 run(zone, f) { |
| (...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5327 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(dart.d
ynamic, [dart.dynamic])]], | 5143 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(dart.d
ynamic, [dart.dynamic])]], |
| 5328 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])]], | 5144 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])]], |
| 5329 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]], | 5145 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]], |
| 5330 scheduleMicrotask: [dart.void, [Zone, dart.functionType(dart.dynamic, [])]
], | 5146 scheduleMicrotask: [dart.void, [Zone, dart.functionType(dart.dynamic, [])]
], |
| 5331 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, []
)]], | 5147 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, []
)]], |
| 5332 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.
void, [Timer])]], | 5148 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.
void, [Timer])]], |
| 5333 print: [dart.void, [Zone, core.String]], | 5149 print: [dart.void, [Zone, core.String]], |
| 5334 fork: [Zone, [Zone, ZoneSpecification, core.Map]] | 5150 fork: [Zone, [Zone, ZoneSpecification, core.Map]] |
| 5335 }) | 5151 }) |
| 5336 }); | 5152 }); |
| 5153 class _Zone extends core.Object { |
| 5154 _Zone() { |
| 5155 } |
| 5156 inSameErrorZone(otherZone) { |
| 5157 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); |
| 5158 } |
| 5159 } |
| 5160 _Zone[dart.implements] = () => [Zone]; |
| 5161 dart.setSignature(_Zone, { |
| 5162 constructors: () => ({_Zone: [_Zone, []]}), |
| 5163 methods: () => ({inSameErrorZone: [core.bool, [Zone]]}) |
| 5164 }); |
| 5337 const _delegateCache = Symbol('_delegateCache'); | 5165 const _delegateCache = Symbol('_delegateCache'); |
| 5166 const _map = Symbol('_map'); |
| 5338 class _CustomZone extends _Zone { | 5167 class _CustomZone extends _Zone { |
| 5339 get [_delegate]() { | 5168 get [_delegate]() { |
| 5340 if (this[_delegateCache] != null) return this[_delegateCache]; | 5169 if (this[_delegateCache] != null) return this[_delegateCache]; |
| 5341 this[_delegateCache] = new _ZoneDelegate(this); | 5170 this[_delegateCache] = new _ZoneDelegate(this); |
| 5342 return this[_delegateCache]; | 5171 return this[_delegateCache]; |
| 5343 } | 5172 } |
| 5344 _CustomZone(parent, specification, map) { | 5173 _CustomZone(parent, specification, map) { |
| 5345 this.parent = parent; | 5174 this.parent = parent; |
| 5346 this[_map] = map; | 5175 this[_map] = map; |
| 5347 this[_runUnary] = null; | 5176 this[_runUnary] = null; |
| (...skipping 340 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5688 return _rootCreatePeriodicTimer; | 5517 return _rootCreatePeriodicTimer; |
| 5689 } | 5518 } |
| 5690 get print() { | 5519 get print() { |
| 5691 return _rootPrint; | 5520 return _rootPrint; |
| 5692 } | 5521 } |
| 5693 get fork() { | 5522 get fork() { |
| 5694 return _rootFork; | 5523 return _rootFork; |
| 5695 } | 5524 } |
| 5696 } | 5525 } |
| 5697 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; | 5526 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
| 5527 class _RootZone extends _Zone { |
| 5528 _RootZone() { |
| 5529 super._Zone(); |
| 5530 } |
| 5531 get [_run]() { |
| 5532 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun)); |
| 5533 } |
| 5534 get [_runUnary]() { |
| 5535 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary)); |
| 5536 } |
| 5537 get [_runBinary]() { |
| 5538 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary)); |
| 5539 } |
| 5540 get [_registerCallback]() { |
| 5541 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback)); |
| 5542 } |
| 5543 get [_registerUnaryCallback]() { |
| 5544 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback
)); |
| 5545 } |
| 5546 get [_registerBinaryCallback]() { |
| 5547 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallbac
k)); |
| 5548 } |
| 5549 get [_errorCallback]() { |
| 5550 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback)); |
| 5551 } |
| 5552 get [_scheduleMicrotask]() { |
| 5553 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask)); |
| 5554 } |
| 5555 get [_createTimer]() { |
| 5556 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer)); |
| 5557 } |
| 5558 get [_createPeriodicTimer]() { |
| 5559 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer))
; |
| 5560 } |
| 5561 get [_print]() { |
| 5562 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint)); |
| 5563 } |
| 5564 get [_fork]() { |
| 5565 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork)); |
| 5566 } |
| 5567 get [_handleUncaughtError]() { |
| 5568 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError))
; |
| 5569 } |
| 5570 get parent() { |
| 5571 return null; |
| 5572 } |
| 5573 get [_map]() { |
| 5574 return _RootZone._rootMap; |
| 5575 } |
| 5576 get [_delegate]() { |
| 5577 if (_RootZone._rootDelegate != null) return _RootZone._rootDelegate; |
| 5578 return _RootZone._rootDelegate = new _ZoneDelegate(this); |
| 5579 } |
| 5580 get errorZone() { |
| 5581 return this; |
| 5582 } |
| 5583 runGuarded(f) { |
| 5584 try { |
| 5585 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) { |
| 5586 return f(); |
| 5587 } |
| 5588 return _rootRun(null, null, this, f); |
| 5589 } catch (e) { |
| 5590 let s = dart.stackTrace(e); |
| 5591 return this.handleUncaughtError(e, s); |
| 5592 } |
| 5593 |
| 5594 } |
| 5595 runUnaryGuarded(f, arg) { |
| 5596 try { |
| 5597 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) { |
| 5598 return dart.dcall(f, arg); |
| 5599 } |
| 5600 return _rootRunUnary(null, null, this, f, arg); |
| 5601 } catch (e) { |
| 5602 let s = dart.stackTrace(e); |
| 5603 return this.handleUncaughtError(e, s); |
| 5604 } |
| 5605 |
| 5606 } |
| 5607 runBinaryGuarded(f, arg1, arg2) { |
| 5608 try { |
| 5609 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) { |
| 5610 return dart.dcall(f, arg1, arg2); |
| 5611 } |
| 5612 return _rootRunBinary(null, null, this, f, arg1, arg2); |
| 5613 } catch (e) { |
| 5614 let s = dart.stackTrace(e); |
| 5615 return this.handleUncaughtError(e, s); |
| 5616 } |
| 5617 |
| 5618 } |
| 5619 bindCallback(f, opts) { |
| 5620 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5621 if (dart.notNull(runGuarded)) { |
| 5622 return dart.fn((() => this.runGuarded(f)).bind(this)); |
| 5623 } else { |
| 5624 return dart.fn((() => this.run(f)).bind(this)); |
| 5625 } |
| 5626 } |
| 5627 bindUnaryCallback(f, opts) { |
| 5628 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5629 if (dart.notNull(runGuarded)) { |
| 5630 return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this)); |
| 5631 } else { |
| 5632 return dart.fn((arg => this.runUnary(f, arg)).bind(this)); |
| 5633 } |
| 5634 } |
| 5635 bindBinaryCallback(f, opts) { |
| 5636 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| 5637 if (dart.notNull(runGuarded)) { |
| 5638 return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bi
nd(this)); |
| 5639 } else { |
| 5640 return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this
)); |
| 5641 } |
| 5642 } |
| 5643 get(key) { |
| 5644 return null; |
| 5645 } |
| 5646 handleUncaughtError(error, stackTrace) { |
| 5647 return _rootHandleUncaughtError(null, null, this, error, stackTrace); |
| 5648 } |
| 5649 fork(opts) { |
| 5650 let specification = opts && 'specification' in opts ? opts.specification :
null; |
| 5651 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
| 5652 return _rootFork(null, null, this, specification, zoneValues); |
| 5653 } |
| 5654 run(f) { |
| 5655 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return f(); |
| 5656 return _rootRun(null, null, this, f); |
| 5657 } |
| 5658 runUnary(f, arg) { |
| 5659 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d
call(f, arg); |
| 5660 return _rootRunUnary(null, null, this, f, arg); |
| 5661 } |
| 5662 runBinary(f, arg1, arg2) { |
| 5663 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d
call(f, arg1, arg2); |
| 5664 return _rootRunBinary(null, null, this, f, arg1, arg2); |
| 5665 } |
| 5666 registerCallback(f) { |
| 5667 return f; |
| 5668 } |
| 5669 registerUnaryCallback(f) { |
| 5670 return f; |
| 5671 } |
| 5672 registerBinaryCallback(f) { |
| 5673 return f; |
| 5674 } |
| 5675 errorCallback(error, stackTrace) { |
| 5676 return null; |
| 5677 } |
| 5678 scheduleMicrotask(f) { |
| 5679 _rootScheduleMicrotask(null, null, this, f); |
| 5680 } |
| 5681 createTimer(duration, f) { |
| 5682 return Timer._createTimer(duration, f); |
| 5683 } |
| 5684 createPeriodicTimer(duration, f) { |
| 5685 return Timer._createPeriodicTimer(duration, f); |
| 5686 } |
| 5687 print(line) { |
| 5688 _internal.printToConsole(line); |
| 5689 } |
| 5690 } |
| 5691 dart.setSignature(_RootZone, { |
| 5692 constructors: () => ({_RootZone: [_RootZone, []]}), |
| 5693 methods: () => ({ |
| 5694 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], |
| 5695 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn
amic]), dart.dynamic]], |
| 5696 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy
namic, dart.dynamic]), dart.dynamic, dart.dynamic]], |
| 5697 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGu
arded: core.bool}], |
| 5698 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d
art.dynamic])], {runGuarded: core.bool}], |
| 5699 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic,
[dart.dynamic, dart.dynamic])], {runGuarded: core.bool}], |
| 5700 get: [dart.dynamic, [core.Object]], |
| 5701 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]], |
| 5702 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, |
| 5703 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], |
| 5704 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]),
dart.dynamic]], |
| 5705 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic,
dart.dynamic]), dart.dynamic, dart.dynamic]], |
| 5706 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]], |
| 5707 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic
, [dart.dynamic])]], |
| 5708 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam
ic, [dart.dynamic, dart.dynamic])]], |
| 5709 errorCallback: [AsyncError, [core.Object, core.StackTrace]], |
| 5710 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], |
| 5711 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
| 5712 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], |
| 5713 print: [dart.void, [core.String]] |
| 5714 }) |
| 5715 }); |
| 5698 _RootZone._rootDelegate = null; | 5716 _RootZone._rootDelegate = null; |
| 5699 dart.defineLazyProperties(_RootZone, { | 5717 dart.defineLazyProperties(_RootZone, { |
| 5700 get _rootMap() { | 5718 get _rootMap() { |
| 5701 return collection.HashMap.new(); | 5719 return collection.HashMap.new(); |
| 5702 }, | 5720 }, |
| 5703 set _rootMap(_) {} | 5721 set _rootMap(_) {} |
| 5704 }); | 5722 }); |
| 5723 const _ROOT_ZONE = dart.const(new _RootZone()); |
| 5705 function runZoned(body, opts) { | 5724 function runZoned(body, opts) { |
| 5706 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 5725 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
| 5707 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; | 5726 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; |
| 5708 let onError = opts && 'onError' in opts ? opts.onError : null; | 5727 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 5709 let errorHandler = null; | 5728 let errorHandler = null; |
| 5710 if (onError != null) { | 5729 if (onError != null) { |
| 5711 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { | 5730 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { |
| 5712 try { | 5731 try { |
| 5713 if (dart.is(onError, ZoneBinaryCallback)) { | 5732 if (dart.is(onError, ZoneBinaryCallback)) { |
| 5714 return self.parent.runBinary(onError, error, stackTrace); | 5733 return self.parent.runBinary(onError, error, stackTrace); |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5801 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5820 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5802 exports.CreateTimerHandler = CreateTimerHandler; | 5821 exports.CreateTimerHandler = CreateTimerHandler; |
| 5803 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5822 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5804 exports.PrintHandler = PrintHandler; | 5823 exports.PrintHandler = PrintHandler; |
| 5805 exports.ForkHandler = ForkHandler; | 5824 exports.ForkHandler = ForkHandler; |
| 5806 exports.ZoneSpecification = ZoneSpecification; | 5825 exports.ZoneSpecification = ZoneSpecification; |
| 5807 exports.ZoneDelegate = ZoneDelegate; | 5826 exports.ZoneDelegate = ZoneDelegate; |
| 5808 exports.Zone = Zone; | 5827 exports.Zone = Zone; |
| 5809 exports.runZoned = runZoned; | 5828 exports.runZoned = runZoned; |
| 5810 }); | 5829 }); |
| OLD | NEW |