| OLD | NEW |
| 1 var async = dart.defineLibrary(async, {}); | 1 var async = dart.defineLibrary(async, {}); |
| 2 var core = dart.import(core); | 2 var core = dart.import(core); |
| 3 var _internal = dart.import(_internal); | 3 var _internal = dart.import(_internal); |
| 4 var _js_helper = dart.lazyImport(_js_helper); | 4 var _js_helper = dart.lazyImport(_js_helper); |
| 5 var _isolate_helper = dart.lazyImport(_isolate_helper); | 5 var _isolate_helper = dart.lazyImport(_isolate_helper); |
| 6 var collection = dart.import(collection); | 6 var collection = dart.import(collection); |
| 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { | 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { |
| 8 'use strict'; | 8 'use strict'; |
| 9 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic | 9 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic |
| 10 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 10 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 return null; | 45 return null; |
| 46 } | 46 } |
| 47 toString() { | 47 toString() { |
| 48 let result = `Uncaught Error: ${this.error}`; | 48 let result = `Uncaught Error: ${this.error}`; |
| 49 if (this.stackTrace != null) { | 49 if (this.stackTrace != null) { |
| 50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; | 50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; |
| 51 } | 51 } |
| 52 return result; | 52 return result; |
| 53 } | 53 } |
| 54 } | 54 } |
| 55 let __CastType0 = dart.typedef('__CastType0', dart.functionType(dart.dynamic,
[dart.dynamic])); | 55 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); |
| 56 let _add = Symbol('_add'); | 56 let _add = Symbol('_add'); |
| 57 let _closeUnchecked = Symbol('_closeUnchecked'); | 57 let _closeUnchecked = Symbol('_closeUnchecked'); |
| 58 let _addError = Symbol('_addError'); | 58 let _addError = Symbol('_addError'); |
| 59 let _completeError = Symbol('_completeError'); | 59 let _completeError = Symbol('_completeError'); |
| 60 let _complete = Symbol('_complete'); | 60 let _complete = Symbol('_complete'); |
| 61 let _sink = Symbol('_sink'); | 61 let _sink = Symbol('_sink'); |
| 62 let Stream$ = dart.generic(function(T) { | 62 let Stream$ = dart.generic(function(T) { |
| 63 class Stream extends core.Object { | 63 class Stream extends core.Object { |
| 64 Stream() { | 64 Stream() { |
| 65 } | 65 } |
| (...skipping 1641 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1707 if (value === void 0) | 1707 if (value === void 0) |
| 1708 value = null; | 1708 value = null; |
| 1709 return new _Future(); | 1709 return new _Future(); |
| 1710 } | 1710 } |
| 1711 } | 1711 } |
| 1712 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; | 1712 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
| 1713 return _DoneSubscription; | 1713 return _DoneSubscription; |
| 1714 }); | 1714 }); |
| 1715 let _DoneSubscription = _DoneSubscription$(); | 1715 let _DoneSubscription = _DoneSubscription$(); |
| 1716 let __CastType2$ = dart.generic(function(T) { | 1716 let __CastType2$ = dart.generic(function(T) { |
| 1717 let __CastType2 = dart.typedef('__CastType2', dart.functionType(dart.void, [
_BufferingStreamSubscription$(T)])); | 1717 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v
oid, [_BufferingStreamSubscription$(T)])); |
| 1718 return __CastType2; | 1718 return __CastType2; |
| 1719 }); | 1719 }); |
| 1720 let __CastType2 = __CastType2$(); | 1720 let __CastType2 = __CastType2$(); |
| 1721 class DeferredLibrary extends core.Object { | 1721 class DeferredLibrary extends core.Object { |
| 1722 DeferredLibrary(libraryName, opts) { | 1722 DeferredLibrary(libraryName, opts) { |
| 1723 let uri = opts && 'uri' in opts ? opts.uri : null; | 1723 let uri = opts && 'uri' in opts ? opts.uri : null; |
| 1724 this.libraryName = libraryName; | 1724 this.libraryName = libraryName; |
| 1725 this.uri = uri; | 1725 this.uri = uri; |
| 1726 } | 1726 } |
| 1727 load() { | 1727 load() { |
| (...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1944 if (replacement != null) { | 1944 if (replacement != null) { |
| 1945 error = _nonNullError(replacement.error); | 1945 error = _nonNullError(replacement.error); |
| 1946 stackTrace = replacement.stackTrace; | 1946 stackTrace = replacement.stackTrace; |
| 1947 } | 1947 } |
| 1948 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 1948 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
| 1949 } | 1949 } |
| 1950 // Function _nonNullError: (Object) → Object | 1950 // Function _nonNullError: (Object) → Object |
| 1951 function _nonNullError(error) { | 1951 function _nonNullError(error) { |
| 1952 return error != null ? error : new core.NullThrownError(); | 1952 return error != null ? error : new core.NullThrownError(); |
| 1953 } | 1953 } |
| 1954 let __CastType4 = dart.typedef('__CastType4', dart.functionType(dart.dynamic,
[dart.dynamic])); | 1954 let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); |
| 1955 let _FutureOnValue$ = dart.generic(function(T) { | 1955 let _FutureOnValue$ = dart.generic(function(T) { |
| 1956 let _FutureOnValue = dart.typedef('_FutureOnValue', dart.functionType(dart.d
ynamic, [T])); | 1956 let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(
dart.dynamic, [T])); |
| 1957 return _FutureOnValue; | 1957 return _FutureOnValue; |
| 1958 }); | 1958 }); |
| 1959 let _FutureOnValue = _FutureOnValue$(); | 1959 let _FutureOnValue = _FutureOnValue$(); |
| 1960 let _FutureErrorTest = dart.typedef('_FutureErrorTest', dart.functionType(core
.bool, [dart.dynamic])); | 1960 let _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionTyp
e(core.bool, [dart.dynamic])); |
| 1961 let _FutureAction = dart.typedef('_FutureAction', dart.functionType(dart.dynam
ic, [])); | 1961 let _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(dart
.dynamic, [])); |
| 1962 let _Completer$ = dart.generic(function(T) { | 1962 let _Completer$ = dart.generic(function(T) { |
| 1963 class _Completer extends core.Object { | 1963 class _Completer extends core.Object { |
| 1964 _Completer() { | 1964 _Completer() { |
| 1965 this.future = new (_Future$(T))(); | 1965 this.future = new (_Future$(T))(); |
| 1966 } | 1966 } |
| 1967 completeError(error, stackTrace) { | 1967 completeError(error, stackTrace) { |
| 1968 if (stackTrace === void 0) | 1968 if (stackTrace === void 0) |
| 1969 stackTrace = null; | 1969 stackTrace = null; |
| 1970 error = _nonNullError(error); | 1970 error = _nonNullError(error); |
| 1971 if (!dart.notNull(this.future[_mayComplete])) | 1971 if (!dart.notNull(this.future[_mayComplete])) |
| (...skipping 571 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2543 dart.defineNamedConstructor(_Future, 'immediateError'); | 2543 dart.defineNamedConstructor(_Future, 'immediateError'); |
| 2544 return _Future; | 2544 return _Future; |
| 2545 }); | 2545 }); |
| 2546 let _Future = _Future$(); | 2546 let _Future = _Future$(); |
| 2547 _Future._INCOMPLETE = 0; | 2547 _Future._INCOMPLETE = 0; |
| 2548 _Future._PENDING_COMPLETE = 1; | 2548 _Future._PENDING_COMPLETE = 1; |
| 2549 _Future._CHAINED = 2; | 2549 _Future._CHAINED = 2; |
| 2550 _Future._VALUE = 4; | 2550 _Future._VALUE = 4; |
| 2551 _Future._ERROR = 8; | 2551 _Future._ERROR = 8; |
| 2552 let __CastType6$ = dart.generic(function(T) { | 2552 let __CastType6$ = dart.generic(function(T) { |
| 2553 let __CastType6 = dart.typedef('__CastType6', dart.functionType(dart.dynamic
, [T])); | 2553 let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(dart.d
ynamic, [T])); |
| 2554 return __CastType6; | 2554 return __CastType6; |
| 2555 }); | 2555 }); |
| 2556 let __CastType6 = __CastType6$(); | 2556 let __CastType6 = __CastType6$(); |
| 2557 let __CastType8 = dart.typedef('__CastType8', dart.functionType(core.bool, [da
rt.dynamic])); | 2557 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.dynamic])); |
| 2558 let __CastType10 = dart.typedef('__CastType10', dart.functionType(dart.dynamic
, [dart.dynamic])); | 2558 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
| 2559 let _AsyncCallback = dart.typedef('_AsyncCallback', dart.functionType(dart.voi
d, [])); | 2559 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); |
| 2560 class _AsyncCallbackEntry extends core.Object { | 2560 class _AsyncCallbackEntry extends core.Object { |
| 2561 _AsyncCallbackEntry(callback) { | 2561 _AsyncCallbackEntry(callback) { |
| 2562 this.callback = callback; | 2562 this.callback = callback; |
| 2563 this.next = null; | 2563 this.next = null; |
| 2564 } | 2564 } |
| 2565 } | 2565 } |
| 2566 exports._nextCallback = null; | 2566 exports._nextCallback = null; |
| 2567 exports._lastCallback = null; | 2567 exports._lastCallback = null; |
| 2568 exports._lastPriorityCallback = null; | 2568 exports._lastPriorityCallback = null; |
| 2569 exports._isInCallbackLoop = false; | 2569 exports._isInCallbackLoop = false; |
| (...skipping 210 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2780 this[_sink].addError(error, stackTrace); | 2780 this[_sink].addError(error, stackTrace); |
| 2781 } | 2781 } |
| 2782 close() { | 2782 close() { |
| 2783 this[_sink].close(); | 2783 this[_sink].close(); |
| 2784 } | 2784 } |
| 2785 } | 2785 } |
| 2786 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; | 2786 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
| 2787 return _ControllerEventSinkWrapper; | 2787 return _ControllerEventSinkWrapper; |
| 2788 }); | 2788 }); |
| 2789 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); | 2789 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); |
| 2790 let __CastType12 = dart.typedef('__CastType12', dart.functionType(dart.void, [
StreamSubscription])); | 2790 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v
oid, [StreamSubscription])); |
| 2791 let __CastType14 = dart.typedef('__CastType14', dart.functionType(dart.dynamic
, [dart.dynamic, core.StackTrace])); | 2791 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.d
ynamic, [dart.dynamic, core.StackTrace])); |
| 2792 let __CastType17 = dart.typedef('__CastType17', dart.functionType(dart.void, [
])); | 2792 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v
oid, [])); |
| 2793 let __CastType18 = dart.typedef('__CastType18', dart.functionType(dart.void, [
EventSink])); | 2793 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v
oid, [EventSink])); |
| 2794 let StreamController$ = dart.generic(function(T) { | 2794 let StreamController$ = dart.generic(function(T) { |
| 2795 class StreamController extends core.Object { | 2795 class StreamController extends core.Object { |
| 2796 StreamController(opts) { | 2796 StreamController(opts) { |
| 2797 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2797 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 2798 let onPause = opts && 'onPause' in opts ? opts.onPause : null; | 2798 let onPause = opts && 'onPause' in opts ? opts.onPause : null; |
| 2799 let onResume = opts && 'onResume' in opts ? opts.onResume : null; | 2799 let onResume = opts && 'onResume' in opts ? opts.onResume : null; |
| 2800 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2800 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 2801 let sync = opts && 'sync' in opts ? opts.sync : false; | 2801 let sync = opts && 'sync' in opts ? opts.sync : false; |
| 2802 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d
art.notNull(onResume == null) && dart.notNull(onCancel == null)) { | 2802 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d
art.notNull(onResume == null) && dart.notNull(onCancel == null)) { |
| 2803 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC
allbackAsyncStreamController(), StreamController$(T)); | 2803 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC
allbackAsyncStreamController(), StreamController$(T)); |
| (...skipping 336 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3140 } | 3140 } |
| 3141 get [_onResume]() { | 3141 get [_onResume]() { |
| 3142 return null; | 3142 return null; |
| 3143 } | 3143 } |
| 3144 get [_onCancel]() { | 3144 get [_onCancel]() { |
| 3145 return null; | 3145 return null; |
| 3146 } | 3146 } |
| 3147 } | 3147 } |
| 3148 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} | 3148 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} |
| 3149 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} | 3149 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} |
| 3150 let _NotificationHandler = dart.typedef('_NotificationHandler', dart.functionT
ype(dart.dynamic, [])); | 3150 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(dart.dynamic, [])); |
| 3151 // Function _runGuarded: (() → dynamic) → Future<dynamic> | 3151 // Function _runGuarded: (() → dynamic) → Future<dynamic> |
| 3152 function _runGuarded(notificationHandler) { | 3152 function _runGuarded(notificationHandler) { |
| 3153 if (notificationHandler == null) | 3153 if (notificationHandler == null) |
| 3154 return null; | 3154 return null; |
| 3155 try { | 3155 try { |
| 3156 let result = notificationHandler(); | 3156 let result = notificationHandler(); |
| 3157 if (dart.is(result, Future)) | 3157 if (dart.is(result, Future)) |
| 3158 return dart.as(result, Future); | 3158 return dart.as(result, Future); |
| 3159 return null; | 3159 return null; |
| 3160 } catch (e) { | 3160 } catch (e) { |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3254 let _EventDispatch = _EventDispatch$(); | 3254 let _EventDispatch = _EventDispatch$(); |
| 3255 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; | 3255 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; |
| 3256 _BufferingStreamSubscription._STATE_CLOSED = 2; | 3256 _BufferingStreamSubscription._STATE_CLOSED = 2; |
| 3257 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; | 3257 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; |
| 3258 _BufferingStreamSubscription._STATE_CANCELED = 8; | 3258 _BufferingStreamSubscription._STATE_CANCELED = 8; |
| 3259 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; | 3259 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; |
| 3260 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; | 3260 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; |
| 3261 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; | 3261 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; |
| 3262 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; | 3262 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; |
| 3263 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; | 3263 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; |
| 3264 let _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType(
_PendingEvents, [])); |
| 3265 let _isUsed = Symbol('_isUsed'); |
| 3266 let _GeneratedStreamImpl$ = dart.generic(function(T) { |
| 3267 class _GeneratedStreamImpl extends _StreamImpl$(T) { |
| 3268 _GeneratedStreamImpl(pending) { |
| 3269 this[_pending] = pending; |
| 3270 this[_isUsed] = false; |
| 3271 } |
| 3272 [_createSubscription](onData, onError, onDone, cancelOnError) { |
| 3273 dart.as(onData, dart.functionType(dart.void, [T])); |
| 3274 dart.as(onDone, dart.functionType(dart.void, [])); |
| 3275 if (this[_isUsed]) |
| 3276 throw new core.StateError("Stream has already been listened to."); |
| 3277 this[_isUsed] = true; |
| 3278 return dart.as((() => { |
| 3279 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc
elOnError); |
| 3280 _[_setPendingEvents](this[_pending]()); |
| 3281 return _; |
| 3282 }).bind(this)(), StreamSubscription$(T)); |
| 3283 } |
| 3284 } |
| 3285 return _GeneratedStreamImpl; |
| 3286 }); |
| 3287 let _GeneratedStreamImpl = _GeneratedStreamImpl$(); |
| 3264 let _eventScheduled = Symbol('_eventScheduled'); | 3288 let _eventScheduled = Symbol('_eventScheduled'); |
| 3265 class _PendingEvents extends core.Object { | 3289 class _PendingEvents extends core.Object { |
| 3266 _PendingEvents() { | 3290 _PendingEvents() { |
| 3267 this[_state] = _PendingEvents._STATE_UNSCHEDULED; | 3291 this[_state] = _PendingEvents._STATE_UNSCHEDULED; |
| 3268 } | 3292 } |
| 3269 get isScheduled() { | 3293 get isScheduled() { |
| 3270 return this[_state] == _PendingEvents._STATE_SCHEDULED; | 3294 return this[_state] == _PendingEvents._STATE_SCHEDULED; |
| 3271 } | 3295 } |
| 3272 get [_eventScheduled]() { | 3296 get [_eventScheduled]() { |
| 3273 return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SC
HEDULED); | 3297 return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SC
HEDULED); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 3288 return; | 3312 return; |
| 3289 this.handleNext(dispatch); | 3313 this.handleNext(dispatch); |
| 3290 }).bind(this)); | 3314 }).bind(this)); |
| 3291 this[_state] = _PendingEvents._STATE_SCHEDULED; | 3315 this[_state] = _PendingEvents._STATE_SCHEDULED; |
| 3292 } | 3316 } |
| 3293 cancelSchedule() { | 3317 cancelSchedule() { |
| 3294 if (this.isScheduled) | 3318 if (this.isScheduled) |
| 3295 this[_state] = _PendingEvents._STATE_CANCELED; | 3319 this[_state] = _PendingEvents._STATE_CANCELED; |
| 3296 } | 3320 } |
| 3297 } | 3321 } |
| 3298 let _EventGenerator = dart.typedef('_EventGenerator', dart.functionType(_Pendi
ngEvents, [])); | |
| 3299 let _isUsed = Symbol('_isUsed'); | |
| 3300 let _GeneratedStreamImpl$ = dart.generic(function(T) { | |
| 3301 class _GeneratedStreamImpl extends _StreamImpl$(T) { | |
| 3302 _GeneratedStreamImpl(pending) { | |
| 3303 this[_pending] = pending; | |
| 3304 this[_isUsed] = false; | |
| 3305 } | |
| 3306 [_createSubscription](onData, onError, onDone, cancelOnError) { | |
| 3307 dart.as(onData, dart.functionType(dart.void, [T])); | |
| 3308 dart.as(onDone, dart.functionType(dart.void, [])); | |
| 3309 if (this[_isUsed]) | |
| 3310 throw new core.StateError("Stream has already been listened to."); | |
| 3311 this[_isUsed] = true; | |
| 3312 return dart.as((() => { | |
| 3313 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc
elOnError); | |
| 3314 _[_setPendingEvents](this[_pending]()); | |
| 3315 return _; | |
| 3316 }).bind(this)(), StreamSubscription$(T)); | |
| 3317 } | |
| 3318 } | |
| 3319 return _GeneratedStreamImpl; | |
| 3320 }); | |
| 3321 let _GeneratedStreamImpl = _GeneratedStreamImpl$(); | |
| 3322 let _iterator = Symbol('_iterator'); | 3322 let _iterator = Symbol('_iterator'); |
| 3323 let _IterablePendingEvents$ = dart.generic(function(T) { | 3323 let _IterablePendingEvents$ = dart.generic(function(T) { |
| 3324 class _IterablePendingEvents extends _PendingEvents { | 3324 class _IterablePendingEvents extends _PendingEvents { |
| 3325 _IterablePendingEvents(data) { | 3325 _IterablePendingEvents(data) { |
| 3326 this[_iterator] = data[core.$iterator]; | 3326 this[_iterator] = data[core.$iterator]; |
| 3327 super._PendingEvents(); | 3327 super._PendingEvents(); |
| 3328 } | 3328 } |
| 3329 get isEmpty() { | 3329 get isEmpty() { |
| 3330 return this[_iterator] == null; | 3330 return this[_iterator] == null; |
| 3331 } | 3331 } |
| (...skipping 21 matching lines...) Expand all Loading... |
| 3353 clear() { | 3353 clear() { |
| 3354 if (this.isScheduled) | 3354 if (this.isScheduled) |
| 3355 this.cancelSchedule(); | 3355 this.cancelSchedule(); |
| 3356 this[_iterator] = null; | 3356 this[_iterator] = null; |
| 3357 } | 3357 } |
| 3358 } | 3358 } |
| 3359 return _IterablePendingEvents; | 3359 return _IterablePendingEvents; |
| 3360 }); | 3360 }); |
| 3361 let _IterablePendingEvents = _IterablePendingEvents$(); | 3361 let _IterablePendingEvents = _IterablePendingEvents$(); |
| 3362 let _DataHandler$ = dart.generic(function(T) { | 3362 let _DataHandler$ = dart.generic(function(T) { |
| 3363 let _DataHandler = dart.typedef('_DataHandler', dart.functionType(dart.void,
[T])); | 3363 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart
.void, [T])); |
| 3364 return _DataHandler; | 3364 return _DataHandler; |
| 3365 }); | 3365 }); |
| 3366 let _DataHandler = _DataHandler$(); | 3366 let _DataHandler = _DataHandler$(); |
| 3367 let _DoneHandler = dart.typedef('_DoneHandler', dart.functionType(dart.void, [
])); | 3367 let _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.v
oid, [])); |
| 3368 // Function _nullDataHandler: (dynamic) → void | 3368 // Function _nullDataHandler: (dynamic) → void |
| 3369 function _nullDataHandler(value) { | 3369 function _nullDataHandler(value) { |
| 3370 } | 3370 } |
| 3371 // Function _nullErrorHandler: (dynamic, [StackTrace]) → void | 3371 // Function _nullErrorHandler: (dynamic, [StackTrace]) → void |
| 3372 function _nullErrorHandler(error, stackTrace) { | 3372 function _nullErrorHandler(error, stackTrace) { |
| 3373 if (stackTrace === void 0) | 3373 if (stackTrace === void 0) |
| 3374 stackTrace = null; | 3374 stackTrace = null; |
| 3375 Zone.current.handleUncaughtError(error, stackTrace); | 3375 Zone.current.handleUncaughtError(error, stackTrace); |
| 3376 } | 3376 } |
| 3377 // Function _nullDoneHandler: () → void | 3377 // Function _nullDoneHandler: () → void |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3471 this[_next] = this[_previous] = this; | 3471 this[_next] = this[_previous] = this; |
| 3472 } | 3472 } |
| 3473 [_insertBefore](newNext) { | 3473 [_insertBefore](newNext) { |
| 3474 let newPrevious = newNext[_previous]; | 3474 let newPrevious = newNext[_previous]; |
| 3475 newPrevious[_next] = this; | 3475 newPrevious[_next] = this; |
| 3476 newNext[_previous] = this[_previous]; | 3476 newNext[_previous] = this[_previous]; |
| 3477 this[_previous][_next] = newNext; | 3477 this[_previous][_next] = newNext; |
| 3478 this[_previous] = newPrevious; | 3478 this[_previous] = newPrevious; |
| 3479 } | 3479 } |
| 3480 } | 3480 } |
| 3481 let _broadcastCallback = dart.typedef('_broadcastCallback', dart.functionType(
dart.void, [StreamSubscription])); | 3481 let _broadcastCallback = dart.typedef('_broadcastCallback', () => dart.functio
nType(dart.void, [StreamSubscription])); |
| 3482 let _schedule = Symbol('_schedule'); | 3482 let _schedule = Symbol('_schedule'); |
| 3483 let _isSent = Symbol('_isSent'); | 3483 let _isSent = Symbol('_isSent'); |
| 3484 let _isScheduled = Symbol('_isScheduled'); | 3484 let _isScheduled = Symbol('_isScheduled'); |
| 3485 let _DoneStreamSubscription$ = dart.generic(function(T) { | 3485 let _DoneStreamSubscription$ = dart.generic(function(T) { |
| 3486 class _DoneStreamSubscription extends core.Object { | 3486 class _DoneStreamSubscription extends core.Object { |
| 3487 _DoneStreamSubscription(onDone) { | 3487 _DoneStreamSubscription(onDone) { |
| 3488 this[_onDone] = onDone; | 3488 this[_onDone] = onDone; |
| 3489 this[_zone] = Zone.current; | 3489 this[_zone] = Zone.current; |
| 3490 this[_state] = 0; | 3490 this[_state] = 0; |
| 3491 this[_schedule](); | 3491 this[_schedule](); |
| (...skipping 300 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3792 return _StreamIteratorImpl; | 3792 return _StreamIteratorImpl; |
| 3793 }); | 3793 }); |
| 3794 let _StreamIteratorImpl = _StreamIteratorImpl$(); | 3794 let _StreamIteratorImpl = _StreamIteratorImpl$(); |
| 3795 _StreamIteratorImpl._STATE_FOUND = 0; | 3795 _StreamIteratorImpl._STATE_FOUND = 0; |
| 3796 _StreamIteratorImpl._STATE_DONE = 1; | 3796 _StreamIteratorImpl._STATE_DONE = 1; |
| 3797 _StreamIteratorImpl._STATE_MOVING = 2; | 3797 _StreamIteratorImpl._STATE_MOVING = 2; |
| 3798 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 3798 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
| 3799 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 3799 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
| 3800 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 3800 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
| 3801 let __CastType20$ = dart.generic(function(T) { | 3801 let __CastType20$ = dart.generic(function(T) { |
| 3802 let __CastType20 = dart.typedef('__CastType20', dart.functionType(dart.void,
[T])); | 3802 let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart
.void, [T])); |
| 3803 return __CastType20; | 3803 return __CastType20; |
| 3804 }); | 3804 }); |
| 3805 let __CastType20 = __CastType20$(); | 3805 let __CastType20 = __CastType20$(); |
| 3806 let __CastType22 = dart.typedef('__CastType22', dart.functionType(dart.dynamic
, [dart.dynamic, dart.dynamic])); | 3806 let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic])); |
| 3807 let __CastType25 = dart.typedef('__CastType25', dart.functionType(dart.dynamic
, [dart.dynamic])); | 3807 let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
| 3808 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT
race) → dynamic) → dynamic | 3808 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT
race) → dynamic) → dynamic |
| 3809 function _runUserCode(userCode, onSuccess, onError) { | 3809 function _runUserCode(userCode, onSuccess, onError) { |
| 3810 try { | 3810 try { |
| 3811 dart.dcall(onSuccess, userCode()); | 3811 dart.dcall(onSuccess, userCode()); |
| 3812 } catch (e) { | 3812 } catch (e) { |
| 3813 let s = dart.stackTrace(e); | 3813 let s = dart.stackTrace(e); |
| 3814 let replacement = Zone.current.errorCallback(e, s); | 3814 let replacement = Zone.current.errorCallback(e, s); |
| 3815 if (replacement == null) { | 3815 if (replacement == null) { |
| 3816 dart.dcall(onError, e, s); | 3816 dart.dcall(onError, e, s); |
| 3817 } else { | 3817 } else { |
| (...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3942 this[_stream][_handleError](error, stackTrace, this); | 3942 this[_stream][_handleError](error, stackTrace, this); |
| 3943 } | 3943 } |
| 3944 [_handleDone]() { | 3944 [_handleDone]() { |
| 3945 this[_stream][_handleDone](this); | 3945 this[_stream][_handleDone](this); |
| 3946 } | 3946 } |
| 3947 } | 3947 } |
| 3948 return _ForwardingStreamSubscription; | 3948 return _ForwardingStreamSubscription; |
| 3949 }); | 3949 }); |
| 3950 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); | 3950 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); |
| 3951 let _Predicate$ = dart.generic(function(T) { | 3951 let _Predicate$ = dart.generic(function(T) { |
| 3952 let _Predicate = dart.typedef('_Predicate', dart.functionType(core.bool, [T]
)); | 3952 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); |
| 3953 return _Predicate; | 3953 return _Predicate; |
| 3954 }); | 3954 }); |
| 3955 let _Predicate = _Predicate$(); | 3955 let _Predicate = _Predicate$(); |
| 3956 // Function _addErrorWithReplacement: (_EventSink<dynamic>, dynamic, dynamic)
→ void | 3956 // Function _addErrorWithReplacement: (_EventSink<dynamic>, dynamic, dynamic)
→ void |
| 3957 function _addErrorWithReplacement(sink, error, stackTrace) { | 3957 function _addErrorWithReplacement(sink, error, stackTrace) { |
| 3958 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); | 3958 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); |
| 3959 if (replacement != null) { | 3959 if (replacement != null) { |
| 3960 error = _nonNullError(replacement.error); | 3960 error = _nonNullError(replacement.error); |
| 3961 stackTrace = replacement.stackTrace; | 3961 stackTrace = replacement.stackTrace; |
| 3962 } | 3962 } |
| (...skipping 20 matching lines...) Expand all Loading... |
| 3983 | 3983 |
| 3984 if (satisfies) { | 3984 if (satisfies) { |
| 3985 sink[_add](inputEvent); | 3985 sink[_add](inputEvent); |
| 3986 } | 3986 } |
| 3987 } | 3987 } |
| 3988 } | 3988 } |
| 3989 return _WhereStream; | 3989 return _WhereStream; |
| 3990 }); | 3990 }); |
| 3991 let _WhereStream = _WhereStream$(); | 3991 let _WhereStream = _WhereStream$(); |
| 3992 let _Transformation$ = dart.generic(function(S, T) { | 3992 let _Transformation$ = dart.generic(function(S, T) { |
| 3993 let _Transformation = dart.typedef('_Transformation', dart.functionType(T, [
S])); | 3993 let _Transformation = dart.typedef('_Transformation', () => dart.functionTyp
e(T, [S])); |
| 3994 return _Transformation; | 3994 return _Transformation; |
| 3995 }); | 3995 }); |
| 3996 let _Transformation = _Transformation$(); | 3996 let _Transformation = _Transformation$(); |
| 3997 let _transform = Symbol('_transform'); | 3997 let _transform = Symbol('_transform'); |
| 3998 let _MapStream$ = dart.generic(function(S, T) { | 3998 let _MapStream$ = dart.generic(function(S, T) { |
| 3999 class _MapStream extends _ForwardingStream$(S, T) { | 3999 class _MapStream extends _ForwardingStream$(S, T) { |
| 4000 _MapStream(source, transform) { | 4000 _MapStream(source, transform) { |
| 4001 this[_transform] = transform; | 4001 this[_transform] = transform; |
| 4002 super._ForwardingStream(source); | 4002 super._ForwardingStream(source); |
| 4003 } | 4003 } |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4036 } catch (e) { | 4036 } catch (e) { |
| 4037 let s = dart.stackTrace(e); | 4037 let s = dart.stackTrace(e); |
| 4038 _addErrorWithReplacement(sink, e, s); | 4038 _addErrorWithReplacement(sink, e, s); |
| 4039 } | 4039 } |
| 4040 | 4040 |
| 4041 } | 4041 } |
| 4042 } | 4042 } |
| 4043 return _ExpandStream; | 4043 return _ExpandStream; |
| 4044 }); | 4044 }); |
| 4045 let _ExpandStream = _ExpandStream$(); | 4045 let _ExpandStream = _ExpandStream$(); |
| 4046 let _ErrorTest = dart.typedef('_ErrorTest', dart.functionType(core.bool, [dart
.dynamic])); | 4046 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool,
[dart.dynamic])); |
| 4047 let _HandleErrorStream$ = dart.generic(function(T) { | 4047 let _HandleErrorStream$ = dart.generic(function(T) { |
| 4048 class _HandleErrorStream extends _ForwardingStream$(T, T) { | 4048 class _HandleErrorStream extends _ForwardingStream$(T, T) { |
| 4049 _HandleErrorStream(source, onError, test) { | 4049 _HandleErrorStream(source, onError, test) { |
| 4050 this[_transform] = onError; | 4050 this[_transform] = onError; |
| 4051 this[_test] = test; | 4051 this[_test] = test; |
| 4052 super._ForwardingStream(source); | 4052 super._ForwardingStream(source); |
| 4053 } | 4053 } |
| 4054 [_handleError](error, stackTrace, sink) { | 4054 [_handleError](error, stackTrace, sink) { |
| 4055 dart.as(sink, _EventSink$(T)); | 4055 dart.as(sink, _EventSink$(T)); |
| 4056 let matches = true; | 4056 let matches = true; |
| (...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4187 if (!dart.notNull(satisfies)) { | 4187 if (!dart.notNull(satisfies)) { |
| 4188 this[_hasFailed] = true; | 4188 this[_hasFailed] = true; |
| 4189 sink[_add](inputEvent); | 4189 sink[_add](inputEvent); |
| 4190 } | 4190 } |
| 4191 } | 4191 } |
| 4192 } | 4192 } |
| 4193 return _SkipWhileStream; | 4193 return _SkipWhileStream; |
| 4194 }); | 4194 }); |
| 4195 let _SkipWhileStream = _SkipWhileStream$(); | 4195 let _SkipWhileStream = _SkipWhileStream$(); |
| 4196 let _Equality$ = dart.generic(function(T) { | 4196 let _Equality$ = dart.generic(function(T) { |
| 4197 let _Equality = dart.typedef('_Equality', dart.functionType(core.bool, [T, T
])); | 4197 let _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool,
[T, T])); |
| 4198 return _Equality; | 4198 return _Equality; |
| 4199 }); | 4199 }); |
| 4200 let _Equality = _Equality$(); | 4200 let _Equality = _Equality$(); |
| 4201 let _equals = Symbol('_equals'); | 4201 let _equals = Symbol('_equals'); |
| 4202 let _DistinctStream$ = dart.generic(function(T) { | 4202 let _DistinctStream$ = dart.generic(function(T) { |
| 4203 class _DistinctStream extends _ForwardingStream$(T, T) { | 4203 class _DistinctStream extends _ForwardingStream$(T, T) { |
| 4204 _DistinctStream(source, equals) { | 4204 _DistinctStream(source, equals) { |
| 4205 this[_previous] = _DistinctStream$()._SENTINEL; | 4205 this[_previous] = _DistinctStream$()._SENTINEL; |
| 4206 this[_equals] = equals; | 4206 this[_equals] = equals; |
| 4207 super._ForwardingStream(source); | 4207 super._ForwardingStream(source); |
| (...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4347 let s = dart.stackTrace(e); | 4347 let s = dart.stackTrace(e); |
| 4348 this[_addError](e, s); | 4348 this[_addError](e, s); |
| 4349 } | 4349 } |
| 4350 | 4350 |
| 4351 } | 4351 } |
| 4352 } | 4352 } |
| 4353 return _SinkTransformerStreamSubscription; | 4353 return _SinkTransformerStreamSubscription; |
| 4354 }); | 4354 }); |
| 4355 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; | 4355 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; |
| 4356 let _SinkMapper$ = dart.generic(function(S, T) { | 4356 let _SinkMapper$ = dart.generic(function(S, T) { |
| 4357 let _SinkMapper = dart.typedef('_SinkMapper', dart.functionType(EventSink$(S
), [EventSink$(T)])); | 4357 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); |
| 4358 return _SinkMapper; | 4358 return _SinkMapper; |
| 4359 }); | 4359 }); |
| 4360 let _SinkMapper = _SinkMapper$(); | 4360 let _SinkMapper = _SinkMapper$(); |
| 4361 let _sinkMapper = Symbol('_sinkMapper'); | 4361 let _sinkMapper = Symbol('_sinkMapper'); |
| 4362 let _StreamSinkTransformer$ = dart.generic(function(S, T) { | 4362 let _StreamSinkTransformer$ = dart.generic(function(S, T) { |
| 4363 class _StreamSinkTransformer extends core.Object { | 4363 class _StreamSinkTransformer extends core.Object { |
| 4364 _StreamSinkTransformer(sinkMapper) { | 4364 _StreamSinkTransformer(sinkMapper) { |
| 4365 this[_sinkMapper] = sinkMapper; | 4365 this[_sinkMapper] = sinkMapper; |
| 4366 } | 4366 } |
| 4367 bind(stream) { | 4367 bind(stream) { |
| (...skipping 23 matching lines...) Expand all Loading... |
| 4391 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 4391 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
| 4392 cancelOnError = core.identical(true, cancelOnError); | 4392 cancelOnError = core.identical(true, cancelOnError); |
| 4393 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic
, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o
nDone, cancelOnError); | 4393 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic
, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o
nDone, cancelOnError); |
| 4394 return subscription; | 4394 return subscription; |
| 4395 } | 4395 } |
| 4396 } | 4396 } |
| 4397 return _BoundSinkStream; | 4397 return _BoundSinkStream; |
| 4398 }); | 4398 }); |
| 4399 let _BoundSinkStream = _BoundSinkStream$(); | 4399 let _BoundSinkStream = _BoundSinkStream$(); |
| 4400 let _TransformDataHandler$ = dart.generic(function(S, T) { | 4400 let _TransformDataHandler$ = dart.generic(function(S, T) { |
| 4401 let _TransformDataHandler = dart.typedef('_TransformDataHandler', dart.funct
ionType(dart.void, [S, EventSink$(T)])); | 4401 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart
.functionType(dart.void, [S, EventSink$(T)])); |
| 4402 return _TransformDataHandler; | 4402 return _TransformDataHandler; |
| 4403 }); | 4403 }); |
| 4404 let _TransformDataHandler = _TransformDataHandler$(); | 4404 let _TransformDataHandler = _TransformDataHandler$(); |
| 4405 let _TransformErrorHandler$ = dart.generic(function(T) { | 4405 let _TransformErrorHandler$ = dart.generic(function(T) { |
| 4406 let _TransformErrorHandler = dart.typedef('_TransformErrorHandler', dart.fun
ctionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)])); | 4406 let _TransformErrorHandler = dart.typedef('_TransformErrorHandler', () => da
rt.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)])); |
| 4407 return _TransformErrorHandler; | 4407 return _TransformErrorHandler; |
| 4408 }); | 4408 }); |
| 4409 let _TransformErrorHandler = _TransformErrorHandler$(); | 4409 let _TransformErrorHandler = _TransformErrorHandler$(); |
| 4410 let _TransformDoneHandler$ = dart.generic(function(T) { | 4410 let _TransformDoneHandler$ = dart.generic(function(T) { |
| 4411 let _TransformDoneHandler = dart.typedef('_TransformDoneHandler', dart.funct
ionType(dart.void, [EventSink$(T)])); | 4411 let _TransformDoneHandler = dart.typedef('_TransformDoneHandler', () => dart
.functionType(dart.void, [EventSink$(T)])); |
| 4412 return _TransformDoneHandler; | 4412 return _TransformDoneHandler; |
| 4413 }); | 4413 }); |
| 4414 let _TransformDoneHandler = _TransformDoneHandler$(); | 4414 let _TransformDoneHandler = _TransformDoneHandler$(); |
| 4415 let _HandlerEventSink$ = dart.generic(function(S, T) { | 4415 let _HandlerEventSink$ = dart.generic(function(S, T) { |
| 4416 class _HandlerEventSink extends core.Object { | 4416 class _HandlerEventSink extends core.Object { |
| 4417 _HandlerEventSink(handleData, handleError, handleDone, sink) { | 4417 _HandlerEventSink(handleData, handleError, handleDone, sink) { |
| 4418 this[_handleData] = handleData; | 4418 this[_handleData] = handleData; |
| 4419 this[_handleError] = handleError; | 4419 this[_handleError] = handleError; |
| 4420 this[_handleDone] = handleDone; | 4420 this[_handleDone] = handleDone; |
| 4421 this[_sink] = sink; | 4421 this[_sink] = sink; |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4465 sink.addError(error); | 4465 sink.addError(error); |
| 4466 } | 4466 } |
| 4467 static _defaultHandleDone(sink) { | 4467 static _defaultHandleDone(sink) { |
| 4468 sink.close(); | 4468 sink.close(); |
| 4469 } | 4469 } |
| 4470 } | 4470 } |
| 4471 return _StreamHandlerTransformer; | 4471 return _StreamHandlerTransformer; |
| 4472 }); | 4472 }); |
| 4473 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); | 4473 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); |
| 4474 let _SubscriptionTransformer$ = dart.generic(function(S, T) { | 4474 let _SubscriptionTransformer$ = dart.generic(function(S, T) { |
| 4475 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', dart
.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); | 4475 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () =
> dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); |
| 4476 return _SubscriptionTransformer; | 4476 return _SubscriptionTransformer; |
| 4477 }); | 4477 }); |
| 4478 let _SubscriptionTransformer = _SubscriptionTransformer$(); | 4478 let _SubscriptionTransformer = _SubscriptionTransformer$(); |
| 4479 let _transformer = Symbol('_transformer'); | 4479 let _transformer = Symbol('_transformer'); |
| 4480 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { | 4480 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { |
| 4481 class _StreamSubscriptionTransformer extends core.Object { | 4481 class _StreamSubscriptionTransformer extends core.Object { |
| 4482 _StreamSubscriptionTransformer(transformer) { | 4482 _StreamSubscriptionTransformer(transformer) { |
| 4483 this[_transformer] = transformer; | 4483 this[_transformer] = transformer; |
| 4484 } | 4484 } |
| 4485 bind(stream) { | 4485 bind(stream) { |
| (...skipping 23 matching lines...) Expand all Loading... |
| 4509 result.onData(onData); | 4509 result.onData(onData); |
| 4510 result.onError(onError); | 4510 result.onError(onError); |
| 4511 result.onDone(onDone); | 4511 result.onDone(onDone); |
| 4512 return result; | 4512 return result; |
| 4513 } | 4513 } |
| 4514 } | 4514 } |
| 4515 return _BoundSubscriptionStream; | 4515 return _BoundSubscriptionStream; |
| 4516 }); | 4516 }); |
| 4517 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); | 4517 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); |
| 4518 let __CastType27$ = dart.generic(function(S, T) { | 4518 let __CastType27$ = dart.generic(function(S, T) { |
| 4519 let __CastType27 = dart.typedef('__CastType27', dart.functionType(dart.void,
[S, EventSink$(T)])); | 4519 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart
.void, [S, EventSink$(T)])); |
| 4520 return __CastType27; | 4520 return __CastType27; |
| 4521 }); | 4521 }); |
| 4522 let __CastType27 = __CastType27$(); | 4522 let __CastType27 = __CastType27$(); |
| 4523 let __CastType30$ = dart.generic(function(T) { | 4523 let __CastType30$ = dart.generic(function(T) { |
| 4524 let __CastType30 = dart.typedef('__CastType30', dart.functionType(dart.void,
[core.Object, core.StackTrace, EventSink$(T)])); | 4524 let __CastType30 = dart.typedef('__CastType30', () => dart.functionType(dart
.void, [core.Object, core.StackTrace, EventSink$(T)])); |
| 4525 return __CastType30; | 4525 return __CastType30; |
| 4526 }); | 4526 }); |
| 4527 let __CastType30 = __CastType30$(); | 4527 let __CastType30 = __CastType30$(); |
| 4528 class Timer extends core.Object { | 4528 class Timer extends core.Object { |
| 4529 Timer(duration, callback) { | 4529 Timer(duration, callback) { |
| 4530 if (dart.equals(Zone.current, Zone.ROOT)) { | 4530 if (dart.equals(Zone.current, Zone.ROOT)) { |
| 4531 return Zone.current.createTimer(duration, callback); | 4531 return Zone.current.createTimer(duration, callback); |
| 4532 } | 4532 } |
| 4533 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba
ck, {runGuarded: true})); | 4533 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba
ck, {runGuarded: true})); |
| 4534 } | 4534 } |
| (...skipping 13 matching lines...) Expand all Loading... |
| 4548 return new _isolate_helper.TimerImpl(milliseconds, callback); | 4548 return new _isolate_helper.TimerImpl(milliseconds, callback); |
| 4549 } | 4549 } |
| 4550 static _createPeriodicTimer(duration, callback) { | 4550 static _createPeriodicTimer(duration, callback) { |
| 4551 let milliseconds = duration.inMilliseconds; | 4551 let milliseconds = duration.inMilliseconds; |
| 4552 if (dart.notNull(milliseconds) < 0) | 4552 if (dart.notNull(milliseconds) < 0) |
| 4553 milliseconds = 0; | 4553 milliseconds = 0; |
| 4554 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); | 4554 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); |
| 4555 } | 4555 } |
| 4556 } | 4556 } |
| 4557 dart.defineNamedConstructor(Timer, 'periodic'); | 4557 dart.defineNamedConstructor(Timer, 'periodic'); |
| 4558 let __CastType34 = dart.typedef('__CastType34', dart.functionType(dart.void, [
Timer])); | 4558 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v
oid, [Timer])); |
| 4559 let ZoneCallback = dart.typedef('ZoneCallback', dart.functionType(dart.dynamic
, [])); | 4559 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.d
ynamic, [])); |
| 4560 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', dart.functionType(da
rt.dynamic, [dart.dynamic])); | 4560 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT
ype(dart.dynamic, [dart.dynamic])); |
| 4561 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', dart.functionType(
dart.dynamic, [dart.dynamic, dart.dynamic])); | 4561 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic, dart.dynamic])); |
| 4562 class Zone extends core.Object { | 4562 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', ()
=> dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, cor
e.StackTrace])); |
| 4563 _() { | 4563 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dynam
ic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
| 4564 } | 4564 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType(
dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.d
ynamic]), dart.dynamic])); |
| 4565 static get current() { | 4565 let RunBinaryHandler = dart.typedef('RunBinaryHandler', () => dart.functionTyp
e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic])); |
| 4566 return Zone._current; | 4566 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () => da
rt.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.
dynamic, [])])); |
| 4567 } | 4567 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler'
, () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [dart.dynamic])])); |
| 4568 static _enter(zone) { | 4568 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle
r', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); |
| 4569 dart.assert(zone != null); | 4569 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', () => dart.fun
ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]))
; |
| 4570 dart.assert(!dart.notNull(core.identical(zone, Zone._current))); | 4570 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', () =>
dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d
ynamic, [])])); |
| 4571 let previous = Zone._current; | 4571 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); |
| 4572 Zone._current = zone; | 4572 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); |
| 4573 return previous; | 4573 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); |
| 4574 } | 4574 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); |
| 4575 static _leave(previous) { | 4575 class _ZoneFunction extends core.Object { |
| 4576 dart.assert(previous != null); | 4576 _ZoneFunction(zone, func) { |
| 4577 Zone._current = previous; | 4577 this.zone = zone; |
| 4578 this.function = func; |
| 4578 } | 4579 } |
| 4579 } | 4580 } |
| 4580 dart.defineNamedConstructor(Zone, '_'); | |
| 4581 class ZoneDelegate extends core.Object {} | |
| 4582 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', da
rt.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.Stac
kTrace])); | |
| 4583 let RunHandler = dart.typedef('RunHandler', dart.functionType(dart.dynamic, [Z
one, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | |
| 4584 let RunUnaryHandler = dart.typedef('RunUnaryHandler', dart.functionType(dart.d
ynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic
]), dart.dynamic])); | |
| 4585 let RunBinaryHandler = dart.typedef('RunBinaryHandler', dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynam
ic, dart.dynamic]), dart.dynamic, dart.dynamic])); | |
| 4586 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', dart.fun
ctionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynami
c, [])])); | |
| 4587 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler'
, dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionT
ype(dart.dynamic, [dart.dynamic])])); | |
| 4588 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle
r', dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.functi
onType(dart.dynamic, [dart.dynamic, dart.dynamic])])); | |
| 4589 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', dart.functionT
ype(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace])); | |
| 4590 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', dart.f
unctionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic
, [])])); | |
| 4591 let CreateTimerHandler = dart.typedef('CreateTimerHandler', dart.functionType(
Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, []
)])); | |
| 4592 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', da
rt.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionTy
pe(dart.void, [Timer])])); | |
| 4593 let PrintHandler = dart.typedef('PrintHandler', dart.functionType(dart.void, [
Zone, ZoneDelegate, Zone, core.String])); | |
| 4594 class ZoneSpecification extends core.Object { | 4581 class ZoneSpecification extends core.Object { |
| 4595 ZoneSpecification(opts) { | 4582 ZoneSpecification(opts) { |
| 4596 return new _ZoneSpecification(opts); | 4583 return new _ZoneSpecification(opts); |
| 4597 } | 4584 } |
| 4598 from(other, opts) { | 4585 from(other, opts) { |
| 4599 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; | 4586 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; |
| 4600 let run = opts && 'run' in opts ? opts.run : null; | 4587 let run = opts && 'run' in opts ? opts.run : null; |
| 4601 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; | 4588 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; |
| 4602 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 4589 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
| 4603 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 4590 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
| 4604 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 4591 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
| 4605 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; | 4592 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; |
| 4606 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; | 4593 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; |
| 4607 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; | 4594 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; |
| 4608 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; | 4595 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; |
| 4609 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; | 4596 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; |
| 4610 let print = opts && 'print' in opts ? opts.print : null; | 4597 let print = opts && 'print' in opts ? opts.print : null; |
| 4611 let fork = opts && 'fork' in opts ? opts.fork : null; | 4598 let fork = opts && 'fork' in opts ? opts.fork : null; |
| 4612 return new ZoneSpecification({handleUncaughtError: handleUncaughtError !=
null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run :
other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r
unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba
ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r
egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba
ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb
ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error
Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s
cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c
reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null
? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print
: other.print, fork: fork != null ? fork : other.fork}); | 4599 return new ZoneSpecification({handleUncaughtError: handleUncaughtError !=
null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run :
other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r
unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba
ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r
egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba
ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb
ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error
Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s
cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c
reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null
? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print
: other.print, fork: fork != null ? fork : other.fork}); |
| 4613 } | 4600 } |
| 4614 } | 4601 } |
| 4615 dart.defineNamedConstructor(ZoneSpecification, 'from'); | 4602 dart.defineNamedConstructor(ZoneSpecification, 'from'); |
| 4616 let ForkHandler = dart.typedef('ForkHandler', dart.functionType(Zone, [Zone, Z
oneDelegate, Zone, ZoneSpecification, core.Map])); | |
| 4617 class _ZoneFunction extends core.Object { | |
| 4618 _ZoneFunction(zone, func) { | |
| 4619 this.zone = zone; | |
| 4620 this.function = func; | |
| 4621 } | |
| 4622 } | |
| 4623 class _ZoneSpecification extends core.Object { | 4603 class _ZoneSpecification extends core.Object { |
| 4624 _ZoneSpecification(opts) { | 4604 _ZoneSpecification(opts) { |
| 4625 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; | 4605 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; |
| 4626 let run = opts && 'run' in opts ? opts.run : null; | 4606 let run = opts && 'run' in opts ? opts.run : null; |
| 4627 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; | 4607 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; |
| 4628 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 4608 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
| 4629 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 4609 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
| 4630 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 4610 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
| 4631 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; | 4611 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; |
| 4632 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; | 4612 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; |
| (...skipping 11 matching lines...) Expand all Loading... |
| 4644 this.registerBinaryCallback = registerBinaryCallback; | 4624 this.registerBinaryCallback = registerBinaryCallback; |
| 4645 this.errorCallback = errorCallback; | 4625 this.errorCallback = errorCallback; |
| 4646 this.scheduleMicrotask = scheduleMicrotask; | 4626 this.scheduleMicrotask = scheduleMicrotask; |
| 4647 this.createTimer = createTimer; | 4627 this.createTimer = createTimer; |
| 4648 this.createPeriodicTimer = createPeriodicTimer; | 4628 this.createPeriodicTimer = createPeriodicTimer; |
| 4649 this.print = print; | 4629 this.print = print; |
| 4650 this.fork = fork; | 4630 this.fork = fork; |
| 4651 } | 4631 } |
| 4652 } | 4632 } |
| 4653 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; | 4633 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
| 4634 class ZoneDelegate extends core.Object {} |
| 4635 class Zone extends core.Object { |
| 4636 _() { |
| 4637 } |
| 4638 static get current() { |
| 4639 return Zone._current; |
| 4640 } |
| 4641 static _enter(zone) { |
| 4642 dart.assert(zone != null); |
| 4643 dart.assert(!dart.notNull(core.identical(zone, Zone._current))); |
| 4644 let previous = Zone._current; |
| 4645 Zone._current = zone; |
| 4646 return previous; |
| 4647 } |
| 4648 static _leave(previous) { |
| 4649 dart.assert(previous != null); |
| 4650 Zone._current = previous; |
| 4651 } |
| 4652 } |
| 4653 dart.defineNamedConstructor(Zone, '_'); |
| 4654 class _Zone extends core.Object { | 4654 class _Zone extends core.Object { |
| 4655 _Zone() { | 4655 _Zone() { |
| 4656 } | 4656 } |
| 4657 inSameErrorZone(otherZone) { | 4657 inSameErrorZone(otherZone) { |
| 4658 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); | 4658 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); |
| 4659 } | 4659 } |
| 4660 } | 4660 } |
| 4661 _Zone[dart.implements] = () => [Zone]; | 4661 _Zone[dart.implements] = () => [Zone]; |
| 4662 let _run = Symbol('_run'); | 4662 let _run = Symbol('_run'); |
| 4663 let _runUnary = Symbol('_runUnary'); | 4663 let _runUnary = Symbol('_runUnary'); |
| (...skipping 639 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5303 } else if (errorHandler != null) { | 5303 } else if (errorHandler != null) { |
| 5304 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU
ncaughtError: errorHandler}); | 5304 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU
ncaughtError: errorHandler}); |
| 5305 } | 5305 } |
| 5306 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); | 5306 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); |
| 5307 if (onError != null) { | 5307 if (onError != null) { |
| 5308 return zone.runGuarded(body); | 5308 return zone.runGuarded(body); |
| 5309 } else { | 5309 } else { |
| 5310 return zone.run(body); | 5310 return zone.run(body); |
| 5311 } | 5311 } |
| 5312 } | 5312 } |
| 5313 let __CastType36 = dart.typedef('__CastType36', dart.functionType(dart.void, [
Timer])); | 5313 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); |
| 5314 let __CastType38 = dart.typedef('__CastType38', dart.functionType(dart.dynamic
, [dart.dynamic])); | 5314 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
| 5315 dart.copyProperties(exports, { | 5315 dart.copyProperties(exports, { |
| 5316 get _hasDocument() { | 5316 get _hasDocument() { |
| 5317 return typeof document == 'object'; | 5317 return typeof document == 'object'; |
| 5318 } | 5318 } |
| 5319 }); | 5319 }); |
| 5320 // Exports: | 5320 // Exports: |
| 5321 exports.AsyncError = AsyncError; | 5321 exports.AsyncError = AsyncError; |
| 5322 exports.Stream$ = Stream$; | 5322 exports.Stream$ = Stream$; |
| 5323 exports.Stream = Stream; | 5323 exports.Stream = Stream; |
| 5324 exports.DeferredLibrary = DeferredLibrary; | 5324 exports.DeferredLibrary = DeferredLibrary; |
| (...skipping 17 matching lines...) Expand all Loading... |
| 5342 exports.StreamTransformer$ = StreamTransformer$; | 5342 exports.StreamTransformer$ = StreamTransformer$; |
| 5343 exports.StreamTransformer = StreamTransformer; | 5343 exports.StreamTransformer = StreamTransformer; |
| 5344 exports.StreamIterator$ = StreamIterator$; | 5344 exports.StreamIterator$ = StreamIterator$; |
| 5345 exports.StreamIterator = StreamIterator; | 5345 exports.StreamIterator = StreamIterator; |
| 5346 exports.StreamController$ = StreamController$; | 5346 exports.StreamController$ = StreamController$; |
| 5347 exports.StreamController = StreamController; | 5347 exports.StreamController = StreamController; |
| 5348 exports.Timer = Timer; | 5348 exports.Timer = Timer; |
| 5349 exports.ZoneCallback = ZoneCallback; | 5349 exports.ZoneCallback = ZoneCallback; |
| 5350 exports.ZoneUnaryCallback = ZoneUnaryCallback; | 5350 exports.ZoneUnaryCallback = ZoneUnaryCallback; |
| 5351 exports.ZoneBinaryCallback = ZoneBinaryCallback; | 5351 exports.ZoneBinaryCallback = ZoneBinaryCallback; |
| 5352 exports.Zone = Zone; | |
| 5353 exports.ZoneDelegate = ZoneDelegate; | |
| 5354 exports.HandleUncaughtErrorHandler = HandleUncaughtErrorHandler; | 5352 exports.HandleUncaughtErrorHandler = HandleUncaughtErrorHandler; |
| 5355 exports.RunHandler = RunHandler; | 5353 exports.RunHandler = RunHandler; |
| 5356 exports.RunUnaryHandler = RunUnaryHandler; | 5354 exports.RunUnaryHandler = RunUnaryHandler; |
| 5357 exports.RunBinaryHandler = RunBinaryHandler; | 5355 exports.RunBinaryHandler = RunBinaryHandler; |
| 5358 exports.RegisterCallbackHandler = RegisterCallbackHandler; | 5356 exports.RegisterCallbackHandler = RegisterCallbackHandler; |
| 5359 exports.RegisterUnaryCallbackHandler = RegisterUnaryCallbackHandler; | 5357 exports.RegisterUnaryCallbackHandler = RegisterUnaryCallbackHandler; |
| 5360 exports.RegisterBinaryCallbackHandler = RegisterBinaryCallbackHandler; | 5358 exports.RegisterBinaryCallbackHandler = RegisterBinaryCallbackHandler; |
| 5361 exports.ErrorCallbackHandler = ErrorCallbackHandler; | 5359 exports.ErrorCallbackHandler = ErrorCallbackHandler; |
| 5362 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5360 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5363 exports.CreateTimerHandler = CreateTimerHandler; | 5361 exports.CreateTimerHandler = CreateTimerHandler; |
| 5364 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5362 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5365 exports.PrintHandler = PrintHandler; | 5363 exports.PrintHandler = PrintHandler; |
| 5364 exports.ForkHandler = ForkHandler; |
| 5366 exports.ZoneSpecification = ZoneSpecification; | 5365 exports.ZoneSpecification = ZoneSpecification; |
| 5367 exports.ForkHandler = ForkHandler; | 5366 exports.ZoneDelegate = ZoneDelegate; |
| 5367 exports.Zone = Zone; |
| 5368 exports.runZoned = runZoned; | 5368 exports.runZoned = runZoned; |
| 5369 })(async, core, _internal, _js_helper, _isolate_helper, collection); | 5369 })(async, core, _internal, _js_helper, _isolate_helper, collection); |
| OLD | NEW |