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; |
11 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 11 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
12 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 12 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
13 return dart.dcall(errorHandler, error, stackTrace); | 13 return dart.dcall(errorHandler, error, stackTrace); |
14 } else { | 14 } else { |
15 return dart.dcall(errorHandler, error); | 15 return dart.dcall(errorHandler, error); |
16 } | 16 } |
17 } | 17 } |
18 dart.fn(_invokeErrorHandler, dart.dynamic, [core.Function, core.Object, core.S
tackTrace]); | 18 dart.fn(_invokeErrorHandler, dart.dynamic, [core.Function, core.Object, core.S
tackTrace]); |
19 function _registerErrorHandler(errorHandler, zone) { | 19 function _registerErrorHandler(errorHandler, zone) { |
20 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 20 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
21 return zone.registerBinaryCallback(errorHandler); | 21 return zone.registerBinaryCallback(errorHandler); |
22 } else { | 22 } else { |
23 return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0)); | 23 return zone.registerUnaryCallback(dart.as(errorHandler, dart.functionType(
dart.dynamic, [dart.dynamic]))); |
24 } | 24 } |
25 } | 25 } |
26 dart.fn(_registerErrorHandler, () => dart.definiteFunctionType(core.Function,
[core.Function, Zone])); | 26 dart.fn(_registerErrorHandler, () => dart.definiteFunctionType(core.Function,
[core.Function, Zone])); |
27 class AsyncError extends core.Object { | 27 class AsyncError extends core.Object { |
28 AsyncError(error, stackTrace) { | 28 AsyncError(error, stackTrace) { |
29 this.error = error; | 29 this.error = error; |
30 this.stackTrace = stackTrace; | 30 this.stackTrace = stackTrace; |
31 } | 31 } |
32 toString() { | 32 toString() { |
33 return dart.toString(this.error); | 33 return dart.toString(this.error); |
(...skipping 20 matching lines...) Expand all Loading... |
54 result = result + `\nStack Trace:\n${this.stackTrace}`; | 54 result = result + `\nStack Trace:\n${this.stackTrace}`; |
55 } | 55 } |
56 return result; | 56 return result; |
57 } | 57 } |
58 } | 58 } |
59 dart.setSignature(_UncaughtAsyncError, { | 59 dart.setSignature(_UncaughtAsyncError, { |
60 constructors: () => ({_UncaughtAsyncError: [_UncaughtAsyncError, [dart.dynam
ic, core.StackTrace]]}), | 60 constructors: () => ({_UncaughtAsyncError: [_UncaughtAsyncError, [dart.dynam
ic, core.StackTrace]]}), |
61 statics: () => ({_getBestStackTrace: [core.StackTrace, [dart.dynamic, core.S
tackTrace]]}), | 61 statics: () => ({_getBestStackTrace: [core.StackTrace, [dart.dynamic, core.S
tackTrace]]}), |
62 names: ['_getBestStackTrace'] | 62 names: ['_getBestStackTrace'] |
63 }); | 63 }); |
64 const __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | |
65 const _controller = Symbol('_controller'); | 64 const _controller = Symbol('_controller'); |
66 const _subscribe = Symbol('_subscribe'); | 65 const _subscribe = Symbol('_subscribe'); |
67 const _createSubscription = Symbol('_createSubscription'); | 66 const _createSubscription = Symbol('_createSubscription'); |
68 const _onListen = Symbol('_onListen'); | 67 const _onListen = Symbol('_onListen'); |
69 const _add = Symbol('_add'); | 68 const _add = Symbol('_add'); |
70 const _closeUnchecked = Symbol('_closeUnchecked'); | 69 const _closeUnchecked = Symbol('_closeUnchecked'); |
71 const _addError = Symbol('_addError'); | 70 const _addError = Symbol('_addError'); |
72 const _completeError = Symbol('_completeError'); | 71 const _completeError = Symbol('_completeError'); |
73 const _complete = Symbol('_complete'); | 72 const _complete = Symbol('_complete'); |
74 const _sink = Symbol('_sink'); | 73 const _sink = Symbol('_sink'); |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
137 return new (_BoundSinkStream$(dart.dynamic, T))(source, mapSink); | 136 return new (_BoundSinkStream$(dart.dynamic, T))(source, mapSink); |
138 } | 137 } |
139 get isBroadcast() { | 138 get isBroadcast() { |
140 return false; | 139 return false; |
141 } | 140 } |
142 asBroadcastStream(opts) { | 141 asBroadcastStream(opts) { |
143 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 142 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
144 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 143 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
145 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 144 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
146 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 145 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
147 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType10
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); | 146 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, dart.functio
nType(dart.void, [StreamSubscription])), dart.as(onCancel, dart.functionType(dar
t.void, [StreamSubscription]))); |
148 } | 147 } |
149 where(test) { | 148 where(test) { |
150 dart.as(test, dart.functionType(core.bool, [T])); | 149 dart.as(test, dart.functionType(core.bool, [T])); |
151 return new (_WhereStream$(T))(this, test); | 150 return new (_WhereStream$(T))(this, test); |
152 } | 151 } |
153 map(convert) { | 152 map(convert) { |
154 dart.as(convert, dart.functionType(dart.dynamic, [T])); | 153 dart.as(convert, dart.functionType(dart.dynamic, [T])); |
155 return new (_MapStream$(T, dart.dynamic))(this, convert); | 154 return new (_MapStream$(T, dart.dynamic))(this, convert); |
156 } | 155 } |
157 asyncMap(convert) { | 156 asyncMap(convert) { |
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
260 let result = new (_Future$(T))(); | 259 let result = new (_Future$(T))(); |
261 let seenFirst = false; | 260 let seenFirst = false; |
262 let value = null; | 261 let value = null; |
263 let subscription = null; | 262 let subscription = null; |
264 subscription = this.listen(dart.fn(element => { | 263 subscription = this.listen(dart.fn(element => { |
265 dart.as(element, T); | 264 dart.as(element, T); |
266 if (seenFirst) { | 265 if (seenFirst) { |
267 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { | 266 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { |
268 dart.as(newValue, T); | 267 dart.as(newValue, T); |
269 value = newValue; | 268 value = newValue; |
270 }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription,
result), __CastType12)); | 269 }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription,
result), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))); |
271 } else { | 270 } else { |
272 value = element; | 271 value = element; |
273 seenFirst = true; | 272 seenFirst = true; |
274 } | 273 } |
275 }, dart.void, [T]), {onError: dart.bind(result, _completeError), onDone:
dart.fn(() => { | 274 }, dart.void, [T]), {onError: dart.bind(result, _completeError), onDone:
dart.fn(() => { |
276 if (!seenFirst) { | 275 if (!seenFirst) { |
277 try { | 276 try { |
278 dart.throw(_internal.IterableElementError.noElement()); | 277 dart.throw(_internal.IterableElementError.noElement()); |
279 } catch (e) { | 278 } catch (e) { |
280 let s = dart.stackTrace(e); | 279 let s = dart.stackTrace(e); |
(...skipping 375 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
656 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); | 655 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); |
657 let controller = null; | 656 let controller = null; |
658 let subscription = null; | 657 let subscription = null; |
659 let timer = null; | 658 let timer = null; |
660 let zone = null; | 659 let zone = null; |
661 let timeout2 = null; | 660 let timeout2 = null; |
662 function onData(event) { | 661 function onData(event) { |
663 dart.as(event, T); | 662 dart.as(event, T); |
664 timer.cancel(); | 663 timer.cancel(); |
665 controller.add(event); | 664 controller.add(event); |
666 timer = zone.createTimer(timeLimit, dart.as(timeout2, __CastType15)); | 665 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); |
667 } | 666 } |
668 dart.fn(onData, dart.void, [T]); | 667 dart.fn(onData, dart.void, [T]); |
669 function onError(error, stackTrace) { | 668 function onError(error, stackTrace) { |
670 timer.cancel(); | 669 timer.cancel(); |
671 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); | 670 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); |
672 let eventSink = dart.as(controller, _EventSink$(T)); | 671 let eventSink = dart.as(controller, _EventSink$(T)); |
673 eventSink[_addError](error, stackTrace); | 672 eventSink[_addError](error, stackTrace); |
674 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); | 673 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); |
675 } | 674 } |
676 dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]); | 675 dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]); |
677 function onDone() { | 676 function onDone() { |
678 timer.cancel(); | 677 timer.cancel(); |
679 controller.close(); | 678 controller.close(); |
680 } | 679 } |
681 dart.fn(onDone, dart.void, []); | 680 dart.fn(onDone, dart.void, []); |
682 const onListen = (function() { | 681 const onListen = (function() { |
683 zone = Zone.current; | 682 zone = Zone.current; |
684 if (onTimeout == null) { | 683 if (onTimeout == null) { |
685 timeout2 = dart.fn(() => { | 684 timeout2 = dart.fn(() => { |
686 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); | 685 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); |
687 }); | 686 }); |
688 } else { | 687 } else { |
689 onTimeout = dart.as(zone.registerUnaryCallback(onTimeout), __CastTyp
e16); | 688 onTimeout = dart.as(zone.registerUnaryCallback(onTimeout), dart.func
tionType(dart.void, [EventSink])); |
690 let wrapper = new _ControllerEventSinkWrapper(null); | 689 let wrapper = new _ControllerEventSinkWrapper(null); |
691 timeout2 = dart.fn(() => { | 690 timeout2 = dart.fn(() => { |
692 wrapper[_sink] = controller; | 691 wrapper[_sink] = controller; |
693 zone.runUnaryGuarded(onTimeout, wrapper); | 692 zone.runUnaryGuarded(onTimeout, wrapper); |
694 wrapper[_sink] = null; | 693 wrapper[_sink] = null; |
695 }); | 694 }); |
696 } | 695 } |
697 subscription = this.listen(onData, {onError: onError, onDone: onDone})
; | 696 subscription = this.listen(onData, {onError: onError, onDone: onDone})
; |
698 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); | 697 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); |
699 }).bind(this); | 698 }).bind(this); |
(...skipping 381 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1081 } | 1080 } |
1082 [_sendError](error, stackTrace) { | 1081 [_sendError](error, stackTrace) { |
1083 dart.assert(!dart.notNull(this[_isCanceled])); | 1082 dart.assert(!dart.notNull(this[_isCanceled])); |
1084 dart.assert(!dart.notNull(this[_isPaused])); | 1083 dart.assert(!dart.notNull(this[_isPaused])); |
1085 dart.assert(!dart.notNull(this[_inCallback])); | 1084 dart.assert(!dart.notNull(this[_inCallback])); |
1086 let wasInputPaused = this[_isInputPaused]; | 1085 let wasInputPaused = this[_isInputPaused]; |
1087 const sendError = (function() { | 1086 const sendError = (function() { |
1088 if (dart.notNull(this[_isCanceled]) && !dart.notNull(this[_waitsForCan
cel])) return; | 1087 if (dart.notNull(this[_isCanceled]) && !dart.notNull(this[_waitsForCan
cel])) return; |
1089 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_IN_CALLBACK); | 1088 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_IN_CALLBACK); |
1090 if (dart.is(this[_onError], ZoneBinaryCallback)) { | 1089 if (dart.is(this[_onError], ZoneBinaryCallback)) { |
1091 this[_zone].runBinaryGuarded(dart.as(this[_onError], __CastType18),
error, stackTrace); | 1090 this[_zone].runBinaryGuarded(dart.as(this[_onError], dart.functionTy
pe(dart.dynamic, [dart.dynamic, dart.dynamic])), error, stackTrace); |
1092 } else { | 1091 } else { |
1093 this[_zone].runUnaryGuarded(dart.as(this[_onError], __CastType21), e
rror); | 1092 this[_zone].runUnaryGuarded(dart.as(this[_onError], dart.functionTyp
e(dart.dynamic, [dart.dynamic])), error); |
1094 } | 1093 } |
1095 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt
reamSubscription$()._STATE_IN_CALLBACK); | 1094 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt
reamSubscription$()._STATE_IN_CALLBACK); |
1096 }).bind(this); | 1095 }).bind(this); |
1097 dart.fn(sendError, dart.void, []); | 1096 dart.fn(sendError, dart.void, []); |
1098 if (dart.notNull(this[_cancelOnError])) { | 1097 if (dart.notNull(this[_cancelOnError])) { |
1099 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_WAIT_FOR_CANCEL); | 1098 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_WAIT_FOR_CANCEL); |
1100 this[_cancel](); | 1099 this[_cancel](); |
1101 if (dart.is(this[_cancelFuture], Future)) { | 1100 if (dart.is(this[_cancelFuture], Future)) { |
1102 this[_cancelFuture].whenComplete(sendError); | 1101 this[_cancelFuture].whenComplete(sendError); |
1103 } else { | 1102 } else { |
(...skipping 789 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1893 return Future$().doWhile(dart.fn(() => { | 1892 return Future$().doWhile(dart.fn(() => { |
1894 if (!dart.notNull(iterator.moveNext())) return false; | 1893 if (!dart.notNull(iterator.moveNext())) return false; |
1895 return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).
then(dart.fn(_ => true, core.bool, [dart.dynamic])); | 1894 return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).
then(dart.fn(_ => true, core.bool, [dart.dynamic])); |
1896 }, core.Object, [])); | 1895 }, core.Object, [])); |
1897 } | 1896 } |
1898 static doWhile(f) { | 1897 static doWhile(f) { |
1899 let doneSignal = new _Future(); | 1898 let doneSignal = new _Future(); |
1900 let nextIteration = null; | 1899 let nextIteration = null; |
1901 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { | 1900 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { |
1902 if (dart.notNull(keepGoing)) { | 1901 if (dart.notNull(keepGoing)) { |
1903 Future$().sync(f).then(dart.as(nextIteration, __CastType2), {onError
: dart.bind(doneSignal, _completeError)}); | 1902 Future$().sync(f).then(dart.as(nextIteration, dart.functionType(dart
.dynamic, [dart.dynamic])), {onError: dart.bind(doneSignal, _completeError)}); |
1904 } else { | 1903 } else { |
1905 doneSignal[_complete](null); | 1904 doneSignal[_complete](null); |
1906 } | 1905 } |
1907 }, dart.dynamic, [core.bool]), {runGuarded: true}); | 1906 }, dart.dynamic, [core.bool]), {runGuarded: true}); |
1908 dart.dcall(nextIteration, true); | 1907 dart.dcall(nextIteration, true); |
1909 return doneSignal; | 1908 return doneSignal; |
1910 } | 1909 } |
1911 } | 1910 } |
1912 dart.setSignature(Future, { | 1911 dart.setSignature(Future, { |
1913 constructors: () => ({ | 1912 constructors: () => ({ |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1974 error = _nonNullError(replacement.error); | 1973 error = _nonNullError(replacement.error); |
1975 stackTrace = replacement.stackTrace; | 1974 stackTrace = replacement.stackTrace; |
1976 } | 1975 } |
1977 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 1976 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
1978 } | 1977 } |
1979 dart.fn(_completeWithErrorCallback, () => dart.definiteFunctionType(dart.void,
[_Future, dart.dynamic, dart.dynamic])); | 1978 dart.fn(_completeWithErrorCallback, () => dart.definiteFunctionType(dart.void,
[_Future, dart.dynamic, dart.dynamic])); |
1980 function _nonNullError(error) { | 1979 function _nonNullError(error) { |
1981 return error != null ? error : new core.NullThrownError(); | 1980 return error != null ? error : new core.NullThrownError(); |
1982 } | 1981 } |
1983 dart.fn(_nonNullError, core.Object, [core.Object]); | 1982 dart.fn(_nonNullError, core.Object, [core.Object]); |
1984 const __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | |
1985 const _FutureOnValue$ = dart.generic(function(T) { | 1983 const _FutureOnValue$ = dart.generic(function(T) { |
1986 const _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionTyp
e(dart.dynamic, [T])); | 1984 const _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionTyp
e(dart.dynamic, [T])); |
1987 return _FutureOnValue; | 1985 return _FutureOnValue; |
1988 }); | 1986 }); |
1989 let _FutureOnValue = _FutureOnValue$(); | 1987 let _FutureOnValue = _FutureOnValue$(); |
1990 const _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionT
ype(core.bool, [dart.dynamic])); | 1988 const _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionT
ype(core.bool, [dart.dynamic])); |
1991 const _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(da
rt.dynamic, [])); | 1989 const _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(da
rt.dynamic, [])); |
1992 const _Completer$ = dart.generic(function(T) { | 1990 const _Completer$ = dart.generic(function(T) { |
1993 class _Completer extends core.Object { | 1991 class _Completer extends core.Object { |
1994 _Completer() { | 1992 _Completer() { |
(...skipping 220 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2215 } else { | 2213 } else { |
2216 dart.assert(this[_isChained]); | 2214 dart.assert(this[_isChained]); |
2217 this[_state] = _Future$()._INCOMPLETE; | 2215 this[_state] = _Future$()._INCOMPLETE; |
2218 } | 2216 } |
2219 } | 2217 } |
2220 then(f, opts) { | 2218 then(f, opts) { |
2221 dart.as(f, dart.functionType(dart.dynamic, [T])); | 2219 dart.as(f, dart.functionType(dart.dynamic, [T])); |
2222 let onError = opts && 'onError' in opts ? opts.onError : null; | 2220 let onError = opts && 'onError' in opts ? opts.onError : null; |
2223 let result = new (_Future$())(); | 2221 let result = new (_Future$())(); |
2224 if (!core.identical(result[_zone], _ROOT_ZONE)) { | 2222 if (!core.identical(result[_zone], _ROOT_ZONE)) { |
2225 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType4); | 2223 f = dart.as(result[_zone].registerUnaryCallback(f), dart.functionType(
dart.dynamic, [T])); |
2226 if (onError != null) { | 2224 if (onError != null) { |
2227 onError = _registerErrorHandler(onError, result[_zone]); | 2225 onError = _registerErrorHandler(onError, result[_zone]); |
2228 } | 2226 } |
2229 } | 2227 } |
2230 this[_addListener](new _FutureListener.then(result, f, onError)); | 2228 this[_addListener](new _FutureListener.then(result, f, onError)); |
2231 return result; | 2229 return result; |
2232 } | 2230 } |
2233 catchError(onError, opts) { | 2231 catchError(onError, opts) { |
2234 let test = opts && 'test' in opts ? opts.test : null; | 2232 let test = opts && 'test' in opts ? opts.test : null; |
2235 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); | 2233 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); |
2236 let result = new (_Future$())(); | 2234 let result = new (_Future$())(); |
2237 if (!core.identical(result[_zone], _ROOT_ZONE)) { | 2235 if (!core.identical(result[_zone], _ROOT_ZONE)) { |
2238 onError = _registerErrorHandler(onError, result[_zone]); | 2236 onError = _registerErrorHandler(onError, result[_zone]); |
2239 if (test != null) test = dart.as(result[_zone].registerUnaryCallback(t
est), __CastType6); | 2237 if (test != null) test = dart.as(result[_zone].registerUnaryCallback(t
est), dart.functionType(core.bool, [dart.dynamic])); |
2240 } | 2238 } |
2241 this[_addListener](new _FutureListener.catchError(result, onError, test)
); | 2239 this[_addListener](new _FutureListener.catchError(result, onError, test)
); |
2242 return result; | 2240 return result; |
2243 } | 2241 } |
2244 whenComplete(action) { | 2242 whenComplete(action) { |
2245 dart.as(action, dart.functionType(dart.dynamic, [])); | 2243 dart.as(action, dart.functionType(dart.dynamic, [])); |
2246 let result = new (_Future$(T))(); | 2244 let result = new (_Future$(T))(); |
2247 if (!core.identical(result[_zone], _ROOT_ZONE)) { | 2245 if (!core.identical(result[_zone], _ROOT_ZONE)) { |
2248 action = result[_zone].registerCallback(action); | 2246 action = result[_zone].registerCallback(action); |
2249 } | 2247 } |
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2448 return; | 2446 return; |
2449 } | 2447 } |
2450 | 2448 |
2451 } | 2449 } |
2452 let errorCallback = listener[_onError]; | 2450 let errorCallback = listener[_onError]; |
2453 if (dart.notNull(matchesTest) && errorCallback != null) { | 2451 if (dart.notNull(matchesTest) && errorCallback != null) { |
2454 try { | 2452 try { |
2455 if (dart.is(errorCallback, ZoneBinaryCallback)) { | 2453 if (dart.is(errorCallback, ZoneBinaryCallback)) { |
2456 listenerValueOrError = zone.runBinary(errorCallback, asyncEr
ror.error, asyncError.stackTrace); | 2454 listenerValueOrError = zone.runBinary(errorCallback, asyncEr
ror.error, asyncError.stackTrace); |
2457 } else { | 2455 } else { |
2458 listenerValueOrError = zone.runUnary(dart.as(errorCallback,
__CastType8), asyncError.error); | 2456 listenerValueOrError = zone.runUnary(dart.as(errorCallback,
dart.functionType(dart.dynamic, [dart.dynamic])), asyncError.error); |
2459 } | 2457 } |
2460 } catch (e) { | 2458 } catch (e) { |
2461 let s = dart.stackTrace(e); | 2459 let s = dart.stackTrace(e); |
2462 listenerValueOrError = core.identical(asyncError.error, e) ? a
syncError : new AsyncError(e, s); | 2460 listenerValueOrError = core.identical(asyncError.error, e) ? a
syncError : new AsyncError(e, s); |
2463 listenerHasValue = false; | 2461 listenerHasValue = false; |
2464 return; | 2462 return; |
2465 } | 2463 } |
2466 | 2464 |
2467 listenerHasValue = true; | 2465 listenerHasValue = true; |
2468 } else { | 2466 } else { |
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2617 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] | 2615 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] |
2618 }); | 2616 }); |
2619 _Future._INCOMPLETE = 0; | 2617 _Future._INCOMPLETE = 0; |
2620 _Future._PENDING_COMPLETE = 1; | 2618 _Future._PENDING_COMPLETE = 1; |
2621 _Future._CHAINED = 2; | 2619 _Future._CHAINED = 2; |
2622 _Future._VALUE = 4; | 2620 _Future._VALUE = 4; |
2623 _Future._ERROR = 8; | 2621 _Future._ERROR = 8; |
2624 return _Future; | 2622 return _Future; |
2625 }); | 2623 }); |
2626 let _Future = _Future$(); | 2624 let _Future = _Future$(); |
2627 const __CastType4$ = dart.generic(function(T, S) { | |
2628 const __CastType4 = dart.typedef('__CastType4', () => dart.functionType(S, [
T])); | |
2629 return __CastType4; | |
2630 }); | |
2631 let __CastType4 = __CastType4$(); | |
2632 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(core.b
ool, [dart.dynamic])); | |
2633 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | |
2634 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(
dart.void, [])); | 2625 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(
dart.void, [])); |
2635 class _AsyncCallbackEntry extends core.Object { | 2626 class _AsyncCallbackEntry extends core.Object { |
2636 _AsyncCallbackEntry(callback) { | 2627 _AsyncCallbackEntry(callback) { |
2637 this.callback = callback; | 2628 this.callback = callback; |
2638 this.next = null; | 2629 this.next = null; |
2639 } | 2630 } |
2640 } | 2631 } |
2641 dart.setSignature(_AsyncCallbackEntry, { | 2632 dart.setSignature(_AsyncCallbackEntry, { |
2642 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall
back]]}) | 2633 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall
back]]}) |
2643 }); | 2634 }); |
(...skipping 243 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2887 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr
apper$(T), [EventSink]]}), | 2878 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr
apper$(T), [EventSink]]}), |
2888 methods: () => ({ | 2879 methods: () => ({ |
2889 add: [dart.void, [T]], | 2880 add: [dart.void, [T]], |
2890 addError: [dart.void, [dart.dynamic], [core.StackTrace]], | 2881 addError: [dart.void, [dart.dynamic], [core.StackTrace]], |
2891 close: [dart.void, []] | 2882 close: [dart.void, []] |
2892 }) | 2883 }) |
2893 }); | 2884 }); |
2894 return _ControllerEventSinkWrapper; | 2885 return _ControllerEventSinkWrapper; |
2895 }); | 2886 }); |
2896 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); | 2887 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); |
2897 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart
.void, [StreamSubscription])); | |
2898 const __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart
.dynamic, [dart.dynamic, core.StackTrace])); | |
2899 const __CastType15 = dart.typedef('__CastType15', () => dart.functionType(dart
.void, [])); | |
2900 const __CastType16 = dart.typedef('__CastType16', () => dart.functionType(dart
.void, [EventSink])); | |
2901 const StreamController$ = dart.generic(function(T) { | 2888 const StreamController$ = dart.generic(function(T) { |
2902 class StreamController extends core.Object { | 2889 class StreamController extends core.Object { |
2903 static new(opts) { | 2890 static new(opts) { |
2904 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2891 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
2905 let onPause = opts && 'onPause' in opts ? opts.onPause : null; | 2892 let onPause = opts && 'onPause' in opts ? opts.onPause : null; |
2906 let onResume = opts && 'onResume' in opts ? opts.onResume : null; | 2893 let onResume = opts && 'onResume' in opts ? opts.onResume : null; |
2907 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2894 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
2908 let sync = opts && 'sync' in opts ? opts.sync : false; | 2895 let sync = opts && 'sync' in opts ? opts.sync : false; |
2909 if (onListen == null && onPause == null && onResume == null && onCancel
== null) { | 2896 if (onListen == null && onPause == null && onResume == null && onCancel
== null) { |
2910 return dart.notNull(sync) ? new (_NoCallbackSyncStreamController$(T))(
) : new (_NoCallbackAsyncStreamController$(T))(); | 2897 return dart.notNull(sync) ? new (_NoCallbackSyncStreamController$(T))(
) : new (_NoCallbackAsyncStreamController$(T))(); |
(...skipping 1127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4038 }); | 4025 }); |
4039 _StreamIteratorImpl._STATE_FOUND = 0; | 4026 _StreamIteratorImpl._STATE_FOUND = 0; |
4040 _StreamIteratorImpl._STATE_DONE = 1; | 4027 _StreamIteratorImpl._STATE_DONE = 1; |
4041 _StreamIteratorImpl._STATE_MOVING = 2; | 4028 _StreamIteratorImpl._STATE_MOVING = 2; |
4042 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 4029 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
4043 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 4030 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
4044 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 4031 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
4045 return _StreamIteratorImpl; | 4032 return _StreamIteratorImpl; |
4046 }); | 4033 }); |
4047 let _StreamIteratorImpl = _StreamIteratorImpl$(); | 4034 let _StreamIteratorImpl = _StreamIteratorImpl$(); |
4048 const __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])); | |
4049 const __CastType21 = dart.typedef('__CastType21', () => dart.functionType(dart
.dynamic, [dart.dynamic])); | |
4050 function _runUserCode(userCode, onSuccess, onError) { | 4035 function _runUserCode(userCode, onSuccess, onError) { |
4051 try { | 4036 try { |
4052 dart.dcall(onSuccess, userCode()); | 4037 dart.dcall(onSuccess, userCode()); |
4053 } catch (e) { | 4038 } catch (e) { |
4054 let s = dart.stackTrace(e); | 4039 let s = dart.stackTrace(e); |
4055 let replacement = Zone.current.errorCallback(e, s); | 4040 let replacement = Zone.current.errorCallback(e, s); |
4056 if (replacement == null) { | 4041 if (replacement == null) { |
4057 dart.dcall(onError, e, s); | 4042 dart.dcall(onError, e, s); |
4058 } else { | 4043 } else { |
4059 let error = _nonNullError(replacement.error); | 4044 let error = _nonNullError(replacement.error); |
(...skipping 793 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4853 static new(duration, callback) { | 4838 static new(duration, callback) { |
4854 if (dart.equals(Zone.current, Zone.ROOT)) { | 4839 if (dart.equals(Zone.current, Zone.ROOT)) { |
4855 return Zone.current.createTimer(duration, callback); | 4840 return Zone.current.createTimer(duration, callback); |
4856 } | 4841 } |
4857 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba
ck, {runGuarded: true})); | 4842 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba
ck, {runGuarded: true})); |
4858 } | 4843 } |
4859 static periodic(duration, callback) { | 4844 static periodic(duration, callback) { |
4860 if (dart.equals(Zone.current, Zone.ROOT)) { | 4845 if (dart.equals(Zone.current, Zone.ROOT)) { |
4861 return Zone.current.createPeriodicTimer(duration, callback); | 4846 return Zone.current.createPeriodicTimer(duration, callback); |
4862 } | 4847 } |
4863 return Zone.current.createPeriodicTimer(duration, dart.as(Zone.current.bin
dUnaryCallback(callback, {runGuarded: true}), __CastType23)); | 4848 return Zone.current.createPeriodicTimer(duration, dart.as(Zone.current.bin
dUnaryCallback(callback, {runGuarded: true}), dart.functionType(dart.void, [Time
r]))); |
4864 } | 4849 } |
4865 static run(callback) { | 4850 static run(callback) { |
4866 Timer.new(core.Duration.ZERO, callback); | 4851 Timer.new(core.Duration.ZERO, callback); |
4867 } | 4852 } |
4868 static _createTimer(duration, callback) { | 4853 static _createTimer(duration, callback) { |
4869 let milliseconds = duration.inMilliseconds; | 4854 let milliseconds = duration.inMilliseconds; |
4870 if (dart.notNull(milliseconds) < 0) milliseconds = 0; | 4855 if (dart.notNull(milliseconds) < 0) milliseconds = 0; |
4871 return new _isolate_helper.TimerImpl(milliseconds, callback); | 4856 return new _isolate_helper.TimerImpl(milliseconds, callback); |
4872 } | 4857 } |
4873 static _createPeriodicTimer(duration, callback) { | 4858 static _createPeriodicTimer(duration, callback) { |
4874 let milliseconds = duration.inMilliseconds; | 4859 let milliseconds = duration.inMilliseconds; |
4875 if (dart.notNull(milliseconds) < 0) milliseconds = 0; | 4860 if (dart.notNull(milliseconds) < 0) milliseconds = 0; |
4876 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); | 4861 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); |
4877 } | 4862 } |
4878 } | 4863 } |
4879 dart.setSignature(Timer, { | 4864 dart.setSignature(Timer, { |
4880 constructors: () => ({ | 4865 constructors: () => ({ |
4881 new: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 4866 new: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
4882 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] | 4867 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] |
4883 }), | 4868 }), |
4884 statics: () => ({ | 4869 statics: () => ({ |
4885 run: [dart.void, [dart.functionType(dart.void, [])]], | 4870 run: [dart.void, [dart.functionType(dart.void, [])]], |
4886 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 4871 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
4887 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]] | 4872 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]] |
4888 }), | 4873 }), |
4889 names: ['run', '_createTimer', '_createPeriodicTimer'] | 4874 names: ['run', '_createTimer', '_createPeriodicTimer'] |
4890 }); | 4875 }); |
4891 const __CastType23 = dart.typedef('__CastType23', () => dart.functionType(dart
.void, [Timer])); | |
4892 const ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart
.dynamic, [])); | 4876 const ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart
.dynamic, [])); |
4893 const ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic])); | 4877 const ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic])); |
4894 const ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.funct
ionType(dart.dynamic, [dart.dynamic, dart.dynamic])); | 4878 const ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.funct
ionType(dart.dynamic, [dart.dynamic, dart.dynamic])); |
4895 const HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler',
() => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, c
ore.StackTrace])); | 4879 const HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler',
() => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, c
ore.StackTrace])); |
4896 const RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dyn
amic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | 4880 const RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dyn
amic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
4897 const RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionTyp
e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic]), dart.dynamic])); | 4881 const RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionTyp
e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic]), dart.dynamic])); |
4898 const RunBinaryHandler = dart.typedef('RunBinaryHandler', () => dart.functionT
ype(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [da
rt.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic])); | 4882 const RunBinaryHandler = dart.typedef('RunBinaryHandler', () => dart.functionT
ype(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [da
rt.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic])); |
4899 const RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () =>
dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dar
t.dynamic, [])])); | 4883 const RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () =>
dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dar
t.dynamic, [])])); |
4900 const RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandle
r', () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic])])); | 4884 const RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandle
r', () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic])])); |
4901 const RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHand
ler', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dar
t.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); | 4885 const RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHand
ler', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dar
t.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); |
(...skipping 512 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5414 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [])]); | 5398 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [])]); |
5415 function _rootCreateTimer(self, parent, zone, duration, callback) { | 5399 function _rootCreateTimer(self, parent, zone, duration, callback) { |
5416 if (!core.identical(_ROOT_ZONE, zone)) { | 5400 if (!core.identical(_ROOT_ZONE, zone)) { |
5417 callback = zone.bindCallback(callback); | 5401 callback = zone.bindCallback(callback); |
5418 } | 5402 } |
5419 return Timer._createTimer(duration, callback); | 5403 return Timer._createTimer(duration, callback); |
5420 } | 5404 } |
5421 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); | 5405 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); |
5422 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { | 5406 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { |
5423 if (!core.identical(_ROOT_ZONE, zone)) { | 5407 if (!core.identical(_ROOT_ZONE, zone)) { |
5424 callback = dart.as(zone.bindUnaryCallback(callback), __CastType25); | 5408 callback = dart.as(zone.bindUnaryCallback(callback), dart.functionType(dar
t.void, [Timer])); |
5425 } | 5409 } |
5426 return Timer._createPeriodicTimer(duration, callback); | 5410 return Timer._createPeriodicTimer(duration, callback); |
5427 } | 5411 } |
5428 dart.fn(_rootCreatePeriodicTimer, Timer, [Zone, ZoneDelegate, Zone, core.Durat
ion, dart.functionType(dart.void, [Timer])]); | 5412 dart.fn(_rootCreatePeriodicTimer, Timer, [Zone, ZoneDelegate, Zone, core.Durat
ion, dart.functionType(dart.void, [Timer])]); |
5429 function _rootPrint(self, parent, zone, line) { | 5413 function _rootPrint(self, parent, zone, line) { |
5430 _internal.printToConsole(line); | 5414 _internal.printToConsole(line); |
5431 } | 5415 } |
5432 dart.fn(_rootPrint, dart.void, [Zone, ZoneDelegate, Zone, core.String]); | 5416 dart.fn(_rootPrint, dart.void, [Zone, ZoneDelegate, Zone, core.String]); |
5433 function _printToZone(line) { | 5417 function _printToZone(line) { |
5434 Zone.current.print(line); | 5418 Zone.current.print(line); |
(...skipping 262 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5697 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 5681 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
5698 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; | 5682 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; |
5699 let onError = opts && 'onError' in opts ? opts.onError : null; | 5683 let onError = opts && 'onError' in opts ? opts.onError : null; |
5700 let errorHandler = null; | 5684 let errorHandler = null; |
5701 if (onError != null) { | 5685 if (onError != null) { |
5702 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { | 5686 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { |
5703 try { | 5687 try { |
5704 if (dart.is(onError, ZoneBinaryCallback)) { | 5688 if (dart.is(onError, ZoneBinaryCallback)) { |
5705 return self.parent.runBinary(onError, error, stackTrace); | 5689 return self.parent.runBinary(onError, error, stackTrace); |
5706 } | 5690 } |
5707 return self.parent.runUnary(dart.as(onError, __CastType27), error); | 5691 return self.parent.runUnary(dart.as(onError, dart.functionType(dart.dy
namic, [dart.dynamic])), error); |
5708 } catch (e) { | 5692 } catch (e) { |
5709 let s = dart.stackTrace(e); | 5693 let s = dart.stackTrace(e); |
5710 if (core.identical(e, error)) { | 5694 if (core.identical(e, error)) { |
5711 return parent.handleUncaughtError(zone, error, stackTrace); | 5695 return parent.handleUncaughtError(zone, error, stackTrace); |
5712 } else { | 5696 } else { |
5713 return parent.handleUncaughtError(zone, e, s); | 5697 return parent.handleUncaughtError(zone, e, s); |
5714 } | 5698 } |
5715 } | 5699 } |
5716 | 5700 |
5717 }, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]
); | 5701 }, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]
); |
5718 } | 5702 } |
5719 if (zoneSpecification == null) { | 5703 if (zoneSpecification == null) { |
5720 zoneSpecification = ZoneSpecification.new({handleUncaughtError: errorHandl
er}); | 5704 zoneSpecification = ZoneSpecification.new({handleUncaughtError: errorHandl
er}); |
5721 } else if (errorHandler != null) { | 5705 } else if (errorHandler != null) { |
5722 zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncau
ghtError: errorHandler}); | 5706 zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncau
ghtError: errorHandler}); |
5723 } | 5707 } |
5724 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); | 5708 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); |
5725 if (onError != null) { | 5709 if (onError != null) { |
5726 return zone.runGuarded(body); | 5710 return zone.runGuarded(body); |
5727 } else { | 5711 } else { |
5728 return zone.run(body); | 5712 return zone.run(body); |
5729 } | 5713 } |
5730 } | 5714 } |
5731 dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {zoneVa
lues: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); | 5715 dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {zoneVa
lues: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); |
5732 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart
.void, [Timer])); | |
5733 const __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart
.dynamic, [dart.dynamic])); | |
5734 dart.copyProperties(exports, { | 5716 dart.copyProperties(exports, { |
5735 get _hasDocument() { | 5717 get _hasDocument() { |
5736 return typeof document == 'object'; | 5718 return typeof document == 'object'; |
5737 } | 5719 } |
5738 }); | 5720 }); |
5739 // Exports: | 5721 // Exports: |
5740 exports.AsyncError = AsyncError; | 5722 exports.AsyncError = AsyncError; |
5741 exports.Stream$ = Stream$; | 5723 exports.Stream$ = Stream$; |
5742 exports.Stream = Stream; | 5724 exports.Stream = Stream; |
5743 exports.DeferredLibrary = DeferredLibrary; | 5725 exports.DeferredLibrary = DeferredLibrary; |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5779 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5761 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5780 exports.CreateTimerHandler = CreateTimerHandler; | 5762 exports.CreateTimerHandler = CreateTimerHandler; |
5781 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5763 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5782 exports.PrintHandler = PrintHandler; | 5764 exports.PrintHandler = PrintHandler; |
5783 exports.ForkHandler = ForkHandler; | 5765 exports.ForkHandler = ForkHandler; |
5784 exports.ZoneSpecification = ZoneSpecification; | 5766 exports.ZoneSpecification = ZoneSpecification; |
5785 exports.ZoneDelegate = ZoneDelegate; | 5767 exports.ZoneDelegate = ZoneDelegate; |
5786 exports.Zone = Zone; | 5768 exports.Zone = Zone; |
5787 exports.runZoned = runZoned; | 5769 exports.runZoned = runZoned; |
5788 }); | 5770 }); |
OLD | NEW |