OLD | NEW |
1 dart_library.library('dart/async', null, /* Imports */[ | 1 dart_library.library('dart/async', null, /* Imports */[ |
2 'dart/_runtime', | 2 'dart/_runtime', |
3 'dart/core', | 3 'dart/core', |
4 'dart/_internal', | 4 'dart/_internal', |
5 'dart/collection' | 5 'dart/collection' |
6 ], /* Lazy imports */[ | 6 ], /* Lazy imports */[ |
7 'dart/_isolate_helper' | 7 'dart/_isolate_helper' |
8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { | 8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { |
9 'use strict'; | 9 'use strict'; |
10 let dartx = dart.dartx; | 10 let dartx = dart.dartx; |
(...skipping 26 matching lines...) Expand all Loading... |
37 dart.setSignature(AsyncError, { | 37 dart.setSignature(AsyncError, { |
38 constructors: () => ({AsyncError: [AsyncError, [dart.dynamic, core.StackTrac
e]]}) | 38 constructors: () => ({AsyncError: [AsyncError, [dart.dynamic, core.StackTrac
e]]}) |
39 }); | 39 }); |
40 class _UncaughtAsyncError extends AsyncError { | 40 class _UncaughtAsyncError extends AsyncError { |
41 _UncaughtAsyncError(error, stackTrace) { | 41 _UncaughtAsyncError(error, stackTrace) { |
42 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac
kTrace)); | 42 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac
kTrace)); |
43 } | 43 } |
44 static _getBestStackTrace(error, stackTrace) { | 44 static _getBestStackTrace(error, stackTrace) { |
45 if (stackTrace != null) return stackTrace; | 45 if (stackTrace != null) return stackTrace; |
46 if (dart.is(error, core.Error)) { | 46 if (dart.is(error, core.Error)) { |
47 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); | 47 return error.stackTrace; |
48 } | 48 } |
49 return null; | 49 return null; |
50 } | 50 } |
51 toString() { | 51 toString() { |
52 let result = `Uncaught Error: ${this.error}`; | 52 let result = `Uncaught Error: ${this.error}`; |
53 if (this.stackTrace != null) { | 53 if (this.stackTrace != null) { |
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 } |
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
133 return new (_BoundSinkStream$(dart.dynamic, T))(source, mapSink); | 133 return new (_BoundSinkStream$(dart.dynamic, T))(source, mapSink); |
134 } | 134 } |
135 get isBroadcast() { | 135 get isBroadcast() { |
136 return false; | 136 return false; |
137 } | 137 } |
138 asBroadcastStream(opts) { | 138 asBroadcastStream(opts) { |
139 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 139 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
140 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 140 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
141 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 141 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
142 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 142 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
143 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType12
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); | 143 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType10
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); |
144 } | 144 } |
145 where(test) { | 145 where(test) { |
146 dart.as(test, dart.functionType(core.bool, [T])); | 146 dart.as(test, dart.functionType(core.bool, [T])); |
147 return new (_WhereStream$(T))(this, test); | 147 return new (_WhereStream$(T))(this, test); |
148 } | 148 } |
149 map(convert) { | 149 map(convert) { |
150 dart.as(convert, dart.functionType(dart.dynamic, [T])); | 150 dart.as(convert, dart.functionType(dart.dynamic, [T])); |
151 return new (_MapStream$(T, dart.dynamic))(this, convert); | 151 return new (_MapStream$(T, dart.dynamic))(this, convert); |
152 } | 152 } |
153 asyncMap(convert) { | 153 asyncMap(convert) { |
(...skipping 11 matching lines...) Expand all Loading... |
165 try { | 165 try { |
166 newValue = convert(event); | 166 newValue = convert(event); |
167 } catch (e) { | 167 } catch (e) { |
168 let s = dart.stackTrace(e); | 168 let s = dart.stackTrace(e); |
169 controller.addError(e, s); | 169 controller.addError(e, s); |
170 return; | 170 return; |
171 } | 171 } |
172 | 172 |
173 if (dart.is(newValue, Future)) { | 173 if (dart.is(newValue, Future)) { |
174 subscription.pause(); | 174 subscription.pause(); |
175 dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}),
'whenComplete', dart.bind(subscription, 'resume')); | 175 newValue.then(add, {onError: addError}).whenComplete(dart.bind(sub
scription, 'resume')); |
176 } else { | 176 } else { |
177 controller.add(newValue); | 177 controller.add(newValue); |
178 } | 178 } |
179 }, dart.void, [T]), {onError: addError, onDone: dart.bind(controller,
'close')}); | 179 }, dart.void, [T]), {onError: addError, onDone: dart.bind(controller,
'close')}); |
180 }).bind(this); | 180 }).bind(this); |
181 dart.fn(onListen, dart.void, []); | 181 dart.fn(onListen, dart.void, []); |
182 if (dart.notNull(this.isBroadcast)) { | 182 if (dart.notNull(this.isBroadcast)) { |
183 controller = StreamController.broadcast({onListen: onListen, onCancel:
dart.fn(() => { | 183 controller = StreamController.broadcast({onListen: onListen, onCancel:
dart.fn(() => { |
184 subscription.cancel(); | 184 subscription.cancel(); |
185 }, dart.void, []), sync: true}); | 185 }, dart.void, []), sync: true}); |
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
256 let result = new (_Future$(T))(); | 256 let result = new (_Future$(T))(); |
257 let seenFirst = false; | 257 let seenFirst = false; |
258 let value = null; | 258 let value = null; |
259 let subscription = null; | 259 let subscription = null; |
260 subscription = this.listen(dart.fn(element => { | 260 subscription = this.listen(dart.fn(element => { |
261 dart.as(element, T); | 261 dart.as(element, T); |
262 if (seenFirst) { | 262 if (seenFirst) { |
263 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { | 263 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { |
264 dart.as(newValue, T); | 264 dart.as(newValue, T); |
265 value = newValue; | 265 value = newValue; |
266 }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription,
result), __CastType14)); | 266 }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription,
result), __CastType12)); |
267 } else { | 267 } else { |
268 value = element; | 268 value = element; |
269 seenFirst = true; | 269 seenFirst = true; |
270 } | 270 } |
271 }, dart.void, [T]), {onError: dart.bind(result, _completeError), onDone:
dart.fn(() => { | 271 }, dart.void, [T]), {onError: dart.bind(result, _completeError), onDone:
dart.fn(() => { |
272 if (!seenFirst) { | 272 if (!seenFirst) { |
273 try { | 273 try { |
274 dart.throw(_internal.IterableElementError.noElement()); | 274 dart.throw(_internal.IterableElementError.noElement()); |
275 } catch (e) { | 275 } catch (e) { |
276 let s = dart.stackTrace(e); | 276 let s = dart.stackTrace(e); |
(...skipping 375 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
652 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); | 652 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); |
653 let controller = null; | 653 let controller = null; |
654 let subscription = null; | 654 let subscription = null; |
655 let timer = null; | 655 let timer = null; |
656 let zone = null; | 656 let zone = null; |
657 let timeout2 = null; | 657 let timeout2 = null; |
658 function onData(event) { | 658 function onData(event) { |
659 dart.as(event, T); | 659 dart.as(event, T); |
660 timer.cancel(); | 660 timer.cancel(); |
661 controller.add(event); | 661 controller.add(event); |
662 timer = zone.createTimer(timeLimit, dart.as(timeout2, __CastType17)); | 662 timer = zone.createTimer(timeLimit, dart.as(timeout2, __CastType15)); |
663 } | 663 } |
664 dart.fn(onData, dart.void, [T]); | 664 dart.fn(onData, dart.void, [T]); |
665 function onError(error, stackTrace) { | 665 function onError(error, stackTrace) { |
666 timer.cancel(); | 666 timer.cancel(); |
667 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); | 667 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); |
668 let eventSink = dart.as(controller, _EventSink$(T)); | 668 let eventSink = dart.as(controller, _EventSink$(T)); |
669 eventSink[_addError](error, stackTrace); | 669 eventSink[_addError](error, stackTrace); |
670 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); | 670 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); |
671 } | 671 } |
672 dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]); | 672 dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]); |
673 function onDone() { | 673 function onDone() { |
674 timer.cancel(); | 674 timer.cancel(); |
675 controller.close(); | 675 controller.close(); |
676 } | 676 } |
677 dart.fn(onDone, dart.void, []); | 677 dart.fn(onDone, dart.void, []); |
678 const onListen = (function() { | 678 const onListen = (function() { |
679 zone = Zone.current; | 679 zone = Zone.current; |
680 if (onTimeout == null) { | 680 if (onTimeout == null) { |
681 timeout2 = dart.fn(() => { | 681 timeout2 = dart.fn(() => { |
682 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); | 682 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); |
683 }); | 683 }); |
684 } else { | 684 } else { |
685 onTimeout = dart.as(zone.registerUnaryCallback(onTimeout), __CastTyp
e18); | 685 onTimeout = dart.as(zone.registerUnaryCallback(onTimeout), __CastTyp
e16); |
686 let wrapper = new _ControllerEventSinkWrapper(null); | 686 let wrapper = new _ControllerEventSinkWrapper(null); |
687 timeout2 = dart.fn(() => { | 687 timeout2 = dart.fn(() => { |
688 wrapper[_sink] = controller; | 688 wrapper[_sink] = controller; |
689 zone.runUnaryGuarded(onTimeout, wrapper); | 689 zone.runUnaryGuarded(onTimeout, wrapper); |
690 wrapper[_sink] = null; | 690 wrapper[_sink] = null; |
691 }); | 691 }); |
692 } | 692 } |
693 subscription = this.listen(onData, {onError: onError, onDone: onDone})
; | 693 subscription = this.listen(onData, {onError: onError, onDone: onDone})
; |
694 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); | 694 timer = zone.createTimer(timeLimit, dart.as(timeout2, dart.functionTyp
e(dart.void, []))); |
695 }).bind(this); | 695 }).bind(this); |
(...skipping 204 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
900 } | 900 } |
901 } | 901 } |
902 [_extractPending]() { | 902 [_extractPending]() { |
903 dart.assert(this[_isCanceled]); | 903 dart.assert(this[_isCanceled]); |
904 let events = this[_pending]; | 904 let events = this[_pending]; |
905 this[_pending] = null; | 905 this[_pending] = null; |
906 return events; | 906 return events; |
907 } | 907 } |
908 onData(handleData) { | 908 onData(handleData) { |
909 dart.as(handleData, dart.functionType(dart.void, [T])); | 909 dart.as(handleData, dart.functionType(dart.void, [T])); |
910 if (handleData == null) handleData = dart.as(_nullDataHandler, __CastTyp
e20); | 910 if (handleData == null) handleData = dart.as(_nullDataHandler, __CastTyp
e18); |
911 this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _
DataHandler$(T)); | 911 this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _
DataHandler$(T)); |
912 } | 912 } |
913 onError(handleError) { | 913 onError(handleError) { |
914 if (handleError == null) handleError = _nullErrorHandler; | 914 if (handleError == null) handleError = _nullErrorHandler; |
915 this[_onError] = _registerErrorHandler(handleError, this[_zone]); | 915 this[_onError] = _registerErrorHandler(handleError, this[_zone]); |
916 } | 916 } |
917 onDone(handleDone) { | 917 onDone(handleDone) { |
918 dart.as(handleDone, dart.functionType(dart.void, [])); | 918 dart.as(handleDone, dart.functionType(dart.void, [])); |
919 if (handleDone == null) handleDone = _nullDoneHandler; | 919 if (handleDone == null) handleDone = _nullDoneHandler; |
920 this[_onDone] = this[_zone].registerCallback(handleDone); | 920 this[_onDone] = this[_zone].registerCallback(handleDone); |
(...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1072 } | 1072 } |
1073 [_sendError](error, stackTrace) { | 1073 [_sendError](error, stackTrace) { |
1074 dart.assert(!dart.notNull(this[_isCanceled])); | 1074 dart.assert(!dart.notNull(this[_isCanceled])); |
1075 dart.assert(!dart.notNull(this[_isPaused])); | 1075 dart.assert(!dart.notNull(this[_isPaused])); |
1076 dart.assert(!dart.notNull(this[_inCallback])); | 1076 dart.assert(!dart.notNull(this[_inCallback])); |
1077 let wasInputPaused = this[_isInputPaused]; | 1077 let wasInputPaused = this[_isInputPaused]; |
1078 const sendError = (function() { | 1078 const sendError = (function() { |
1079 if (dart.notNull(this[_isCanceled]) && !dart.notNull(this[_waitsForCan
cel])) return; | 1079 if (dart.notNull(this[_isCanceled]) && !dart.notNull(this[_waitsForCan
cel])) return; |
1080 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_IN_CALLBACK); | 1080 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_IN_CALLBACK); |
1081 if (dart.is(this[_onError], ZoneBinaryCallback)) { | 1081 if (dart.is(this[_onError], ZoneBinaryCallback)) { |
1082 this[_zone].runBinaryGuarded(dart.as(this[_onError], __CastType22),
error, stackTrace); | 1082 this[_zone].runBinaryGuarded(dart.as(this[_onError], __CastType20),
error, stackTrace); |
1083 } else { | 1083 } else { |
1084 this[_zone].runUnaryGuarded(dart.as(this[_onError], __CastType25), e
rror); | 1084 this[_zone].runUnaryGuarded(dart.as(this[_onError], __CastType23), e
rror); |
1085 } | 1085 } |
1086 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt
reamSubscription$()._STATE_IN_CALLBACK); | 1086 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt
reamSubscription$()._STATE_IN_CALLBACK); |
1087 }).bind(this); | 1087 }).bind(this); |
1088 dart.fn(sendError, dart.void, []); | 1088 dart.fn(sendError, dart.void, []); |
1089 if (dart.notNull(this[_cancelOnError])) { | 1089 if (dart.notNull(this[_cancelOnError])) { |
1090 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_WAIT_FOR_CANCEL); | 1090 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStr
eamSubscription$()._STATE_WAIT_FOR_CANCEL); |
1091 this[_cancel](); | 1091 this[_cancel](); |
1092 if (dart.is(this[_cancelFuture], Future)) { | 1092 if (dart.is(this[_cancelFuture], Future)) { |
1093 this[_cancelFuture].whenComplete(sendError); | 1093 this[_cancelFuture].whenComplete(sendError); |
1094 } else { | 1094 } else { |
(...skipping 444 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1539 } | 1539 } |
1540 [_sendError](error, stackTrace) { | 1540 [_sendError](error, stackTrace) { |
1541 if (dart.notNull(this[_isEmpty])) return; | 1541 if (dart.notNull(this[_isEmpty])) return; |
1542 this[_forEachListener](dart.fn(subscription => { | 1542 this[_forEachListener](dart.fn(subscription => { |
1543 dart.as(subscription, _BufferingStreamSubscription$(T)); | 1543 dart.as(subscription, _BufferingStreamSubscription$(T)); |
1544 subscription[_addError](error, stackTrace); | 1544 subscription[_addError](error, stackTrace); |
1545 }, dart.void, [_BufferingStreamSubscription$(T)])); | 1545 }, dart.void, [_BufferingStreamSubscription$(T)])); |
1546 } | 1546 } |
1547 [_sendDone]() { | 1547 [_sendDone]() { |
1548 if (!dart.notNull(this[_isEmpty])) { | 1548 if (!dart.notNull(this[_isEmpty])) { |
1549 this[_forEachListener](dart.as(dart.fn(subscription => { | 1549 this[_forEachListener](dart.fn(subscription => { |
1550 dart.as(subscription, _BroadcastSubscription$(T)); | 1550 dart.as(subscription, _BroadcastSubscription$(T)); |
1551 subscription[_close](); | 1551 subscription[_close](); |
1552 }, dart.void, [_BroadcastSubscription$(T)]), __CastType2)); | 1552 }, dart.void, [_BroadcastSubscription$(T)])); |
1553 } else { | 1553 } else { |
1554 dart.assert(this[_doneFuture] != null); | 1554 dart.assert(this[_doneFuture] != null); |
1555 dart.assert(this[_doneFuture][_mayComplete]); | 1555 dart.assert(this[_doneFuture][_mayComplete]); |
1556 this[_doneFuture][_asyncComplete](null); | 1556 this[_doneFuture][_asyncComplete](null); |
1557 } | 1557 } |
1558 } | 1558 } |
1559 } | 1559 } |
1560 dart.setSignature(_SyncBroadcastStreamController, { | 1560 dart.setSignature(_SyncBroadcastStreamController, { |
1561 constructors: () => ({_SyncBroadcastStreamController: [_SyncBroadcastStrea
mController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void,
[])]]}), | 1561 constructors: () => ({_SyncBroadcastStreamController: [_SyncBroadcastStrea
mController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void,
[])]]}), |
1562 methods: () => ({ | 1562 methods: () => ({ |
(...skipping 162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1725 pause: [dart.void, [], [Future]], | 1725 pause: [dart.void, [], [Future]], |
1726 resume: [dart.void, []], | 1726 resume: [dart.void, []], |
1727 [_resume]: [dart.void, [dart.dynamic]], | 1727 [_resume]: [dart.void, [dart.dynamic]], |
1728 cancel: [Future, []], | 1728 cancel: [Future, []], |
1729 asFuture: [Future, [], [core.Object]] | 1729 asFuture: [Future, [], [core.Object]] |
1730 }) | 1730 }) |
1731 }); | 1731 }); |
1732 return _DoneSubscription; | 1732 return _DoneSubscription; |
1733 }); | 1733 }); |
1734 let _DoneSubscription = _DoneSubscription$(); | 1734 let _DoneSubscription = _DoneSubscription$(); |
1735 const __CastType2$ = dart.generic(function(T) { | |
1736 const __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart
.void, [_BufferingStreamSubscription$(T)])); | |
1737 return __CastType2; | |
1738 }); | |
1739 let __CastType2 = __CastType2$(); | |
1740 class DeferredLibrary extends core.Object { | 1735 class DeferredLibrary extends core.Object { |
1741 DeferredLibrary(libraryName, opts) { | 1736 DeferredLibrary(libraryName, opts) { |
1742 let uri = opts && 'uri' in opts ? opts.uri : null; | 1737 let uri = opts && 'uri' in opts ? opts.uri : null; |
1743 this.libraryName = libraryName; | 1738 this.libraryName = libraryName; |
1744 this.uri = uri; | 1739 this.uri = uri; |
1745 } | 1740 } |
1746 load() { | 1741 load() { |
1747 dart.throw('DeferredLibrary not supported. ' + 'please use the `import "li
b.dart" deferred as lib` syntax.'); | 1742 dart.throw('DeferredLibrary not supported. ' + 'please use the `import "li
b.dart" deferred as lib` syntax.'); |
1748 } | 1743 } |
1749 } | 1744 } |
(...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1901 if (!dart.notNull(iterator.moveNext())) return false; | 1896 if (!dart.notNull(iterator.moveNext())) return false; |
1902 return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).
then(dart.fn(_ => true, core.bool, [dart.dynamic])); | 1897 return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).
then(dart.fn(_ => true, core.bool, [dart.dynamic])); |
1903 })); | 1898 })); |
1904 } | 1899 } |
1905 static doWhile(f) { | 1900 static doWhile(f) { |
1906 dart.as(f, dart.functionType(dart.dynamic, [])); | 1901 dart.as(f, dart.functionType(dart.dynamic, [])); |
1907 let doneSignal = new _Future(); | 1902 let doneSignal = new _Future(); |
1908 let nextIteration = null; | 1903 let nextIteration = null; |
1909 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { | 1904 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { |
1910 if (dart.notNull(keepGoing)) { | 1905 if (dart.notNull(keepGoing)) { |
1911 Future$().sync(f).then(dart.as(nextIteration, __CastType4), {onError
: dart.bind(doneSignal, _completeError)}); | 1906 Future$().sync(f).then(dart.as(nextIteration, __CastType2), {onError
: dart.bind(doneSignal, _completeError)}); |
1912 } else { | 1907 } else { |
1913 doneSignal[_complete](null); | 1908 doneSignal[_complete](null); |
1914 } | 1909 } |
1915 }, dart.dynamic, [core.bool]), {runGuarded: true}); | 1910 }, dart.dynamic, [core.bool]), {runGuarded: true}); |
1916 dart.dcall(nextIteration, true); | 1911 dart.dcall(nextIteration, true); |
1917 return doneSignal; | 1912 return doneSignal; |
1918 } | 1913 } |
1919 } | 1914 } |
1920 dart.setSignature(Future, { | 1915 dart.setSignature(Future, { |
1921 constructors: () => ({ | 1916 constructors: () => ({ |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1982 error = _nonNullError(replacement.error); | 1977 error = _nonNullError(replacement.error); |
1983 stackTrace = replacement.stackTrace; | 1978 stackTrace = replacement.stackTrace; |
1984 } | 1979 } |
1985 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 1980 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
1986 } | 1981 } |
1987 dart.fn(_completeWithErrorCallback, () => dart.definiteFunctionType(dart.void,
[_Future, dart.dynamic, dart.dynamic])); | 1982 dart.fn(_completeWithErrorCallback, () => dart.definiteFunctionType(dart.void,
[_Future, dart.dynamic, dart.dynamic])); |
1988 function _nonNullError(error) { | 1983 function _nonNullError(error) { |
1989 return error != null ? error : new core.NullThrownError(); | 1984 return error != null ? error : new core.NullThrownError(); |
1990 } | 1985 } |
1991 dart.fn(_nonNullError, core.Object, [core.Object]); | 1986 dart.fn(_nonNullError, core.Object, [core.Object]); |
1992 const __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | 1987 const __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
1993 const _FutureOnValue$ = dart.generic(function(T) { | 1988 const _FutureOnValue$ = dart.generic(function(T) { |
1994 const _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionTyp
e(dart.dynamic, [T])); | 1989 const _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionTyp
e(dart.dynamic, [T])); |
1995 return _FutureOnValue; | 1990 return _FutureOnValue; |
1996 }); | 1991 }); |
1997 let _FutureOnValue = _FutureOnValue$(); | 1992 let _FutureOnValue = _FutureOnValue$(); |
1998 const _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionT
ype(core.bool, [dart.dynamic])); | 1993 const _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionT
ype(core.bool, [dart.dynamic])); |
1999 const _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(da
rt.dynamic, [])); | 1994 const _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(da
rt.dynamic, [])); |
2000 const _Completer$ = dart.generic(function(T) { | 1995 const _Completer$ = dart.generic(function(T) { |
2001 class _Completer extends core.Object { | 1996 class _Completer extends core.Object { |
2002 _Completer() { | 1997 _Completer() { |
(...skipping 220 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2223 } else { | 2218 } else { |
2224 dart.assert(this[_isChained]); | 2219 dart.assert(this[_isChained]); |
2225 this[_state] = _Future$()._INCOMPLETE; | 2220 this[_state] = _Future$()._INCOMPLETE; |
2226 } | 2221 } |
2227 } | 2222 } |
2228 then(f, opts) { | 2223 then(f, opts) { |
2229 dart.as(f, dart.functionType(dart.dynamic, [T])); | 2224 dart.as(f, dart.functionType(dart.dynamic, [T])); |
2230 let onError = opts && 'onError' in opts ? opts.onError : null; | 2225 let onError = opts && 'onError' in opts ? opts.onError : null; |
2231 let result = new (_Future$())(); | 2226 let result = new (_Future$())(); |
2232 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2227 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
2233 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType6); | 2228 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType4); |
2234 if (onError != null) { | 2229 if (onError != null) { |
2235 onError = _registerErrorHandler(onError, result[_zone]); | 2230 onError = _registerErrorHandler(onError, result[_zone]); |
2236 } | 2231 } |
2237 } | 2232 } |
2238 this[_addListener](new _FutureListener.then(result, f, onError)); | 2233 this[_addListener](new _FutureListener.then(result, f, onError)); |
2239 return result; | 2234 return result; |
2240 } | 2235 } |
2241 catchError(onError, opts) { | 2236 catchError(onError, opts) { |
2242 let test = opts && 'test' in opts ? opts.test : null; | 2237 let test = opts && 'test' in opts ? opts.test : null; |
2243 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); | 2238 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); |
2244 let result = new (_Future$())(); | 2239 let result = new (_Future$())(); |
2245 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2240 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
2246 onError = _registerErrorHandler(onError, result[_zone]); | 2241 onError = _registerErrorHandler(onError, result[_zone]); |
2247 if (test != null) test = dart.as(result[_zone].registerUnaryCallback(t
est), __CastType8); | 2242 if (test != null) test = dart.as(result[_zone].registerUnaryCallback(t
est), __CastType6); |
2248 } | 2243 } |
2249 this[_addListener](new _FutureListener.catchError(result, onError, test)
); | 2244 this[_addListener](new _FutureListener.catchError(result, onError, test)
); |
2250 return result; | 2245 return result; |
2251 } | 2246 } |
2252 whenComplete(action) { | 2247 whenComplete(action) { |
2253 dart.as(action, dart.functionType(dart.dynamic, [])); | 2248 dart.as(action, dart.functionType(dart.dynamic, [])); |
2254 let result = new (_Future$(T))(); | 2249 let result = new (_Future$(T))(); |
2255 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2250 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
2256 action = result[_zone].registerCallback(action); | 2251 action = result[_zone].registerCallback(action); |
2257 } | 2252 } |
(...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2332 if (dart.notNull(source[_isComplete])) { | 2327 if (dart.notNull(source[_isComplete])) { |
2333 _Future$()._propagateToListeners(source, listener); | 2328 _Future$()._propagateToListeners(source, listener); |
2334 } else { | 2329 } else { |
2335 source[_addListener](listener); | 2330 source[_addListener](listener); |
2336 } | 2331 } |
2337 } | 2332 } |
2338 [_complete](value) { | 2333 [_complete](value) { |
2339 dart.assert(!dart.notNull(this[_isComplete])); | 2334 dart.assert(!dart.notNull(this[_isComplete])); |
2340 if (dart.is(value, Future)) { | 2335 if (dart.is(value, Future)) { |
2341 if (dart.is(value, _Future$())) { | 2336 if (dart.is(value, _Future$())) { |
2342 _Future$()._chainCoreFuture(dart.as(value, _Future$()), this); | 2337 _Future$()._chainCoreFuture(value, this); |
2343 } else { | 2338 } else { |
2344 _Future$()._chainForeignFuture(dart.as(value, Future), this); | 2339 _Future$()._chainForeignFuture(value, this); |
2345 } | 2340 } |
2346 } else { | 2341 } else { |
2347 let listeners = this[_removeListeners](); | 2342 let listeners = this[_removeListeners](); |
2348 this[_setValue](dart.as(value, T)); | 2343 this[_setValue](dart.as(value, T)); |
2349 _Future$()._propagateToListeners(this, listeners); | 2344 _Future$()._propagateToListeners(this, listeners); |
2350 } | 2345 } |
2351 } | 2346 } |
2352 [_completeWithValue](value) { | 2347 [_completeWithValue](value) { |
2353 dart.assert(!dart.notNull(this[_isComplete])); | 2348 dart.assert(!dart.notNull(this[_isComplete])); |
2354 dart.assert(!dart.is(value, Future)); | 2349 dart.assert(!dart.is(value, Future)); |
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2456 return; | 2451 return; |
2457 } | 2452 } |
2458 | 2453 |
2459 } | 2454 } |
2460 let errorCallback = listener[_onError]; | 2455 let errorCallback = listener[_onError]; |
2461 if (dart.notNull(matchesTest) && errorCallback != null) { | 2456 if (dart.notNull(matchesTest) && errorCallback != null) { |
2462 try { | 2457 try { |
2463 if (dart.is(errorCallback, ZoneBinaryCallback)) { | 2458 if (dart.is(errorCallback, ZoneBinaryCallback)) { |
2464 listenerValueOrError = zone.runBinary(errorCallback, asyncEr
ror.error, asyncError.stackTrace); | 2459 listenerValueOrError = zone.runBinary(errorCallback, asyncEr
ror.error, asyncError.stackTrace); |
2465 } else { | 2460 } else { |
2466 listenerValueOrError = zone.runUnary(dart.as(errorCallback,
__CastType10), asyncError.error); | 2461 listenerValueOrError = zone.runUnary(dart.as(errorCallback,
__CastType8), asyncError.error); |
2467 } | 2462 } |
2468 } catch (e) { | 2463 } catch (e) { |
2469 let s = dart.stackTrace(e); | 2464 let s = dart.stackTrace(e); |
2470 listenerValueOrError = dart.notNull(core.identical(asyncError.
error, e)) ? asyncError : new AsyncError(e, s); | 2465 listenerValueOrError = dart.notNull(core.identical(asyncError.
error, e)) ? asyncError : new AsyncError(e, s); |
2471 listenerHasValue = false; | 2466 listenerHasValue = false; |
2472 return; | 2467 return; |
2473 } | 2468 } |
2474 | 2469 |
2475 listenerHasValue = true; | 2470 listenerHasValue = true; |
2476 } else { | 2471 } else { |
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2625 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] | 2620 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] |
2626 }); | 2621 }); |
2627 _Future._INCOMPLETE = 0; | 2622 _Future._INCOMPLETE = 0; |
2628 _Future._PENDING_COMPLETE = 1; | 2623 _Future._PENDING_COMPLETE = 1; |
2629 _Future._CHAINED = 2; | 2624 _Future._CHAINED = 2; |
2630 _Future._VALUE = 4; | 2625 _Future._VALUE = 4; |
2631 _Future._ERROR = 8; | 2626 _Future._ERROR = 8; |
2632 return _Future; | 2627 return _Future; |
2633 }); | 2628 }); |
2634 let _Future = _Future$(); | 2629 let _Future = _Future$(); |
2635 const __CastType6$ = dart.generic(function(T, S) { | 2630 const __CastType4$ = dart.generic(function(T, S) { |
2636 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [
T])); | 2631 const __CastType4 = dart.typedef('__CastType4', () => dart.functionType(S, [
T])); |
2637 return __CastType6; | 2632 return __CastType4; |
2638 }); | 2633 }); |
2639 let __CastType6 = __CastType6$(); | 2634 let __CastType4 = __CastType4$(); |
2640 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.b
ool, [dart.dynamic])); | 2635 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(core.b
ool, [dart.dynamic])); |
2641 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart
.dynamic, [dart.dynamic])); | 2636 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
2642 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(
dart.void, [])); | 2637 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(
dart.void, [])); |
2643 class _AsyncCallbackEntry extends core.Object { | 2638 class _AsyncCallbackEntry extends core.Object { |
2644 _AsyncCallbackEntry(callback) { | 2639 _AsyncCallbackEntry(callback) { |
2645 this.callback = callback; | 2640 this.callback = callback; |
2646 this.next = null; | 2641 this.next = null; |
2647 } | 2642 } |
2648 } | 2643 } |
2649 dart.setSignature(_AsyncCallbackEntry, { | 2644 dart.setSignature(_AsyncCallbackEntry, { |
2650 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall
back]]}) | 2645 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall
back]]}) |
2651 }); | 2646 }); |
(...skipping 243 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2895 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr
apper$(T), [EventSink]]}), | 2890 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr
apper$(T), [EventSink]]}), |
2896 methods: () => ({ | 2891 methods: () => ({ |
2897 add: [dart.void, [T]], | 2892 add: [dart.void, [T]], |
2898 addError: [dart.void, [dart.dynamic], [core.StackTrace]], | 2893 addError: [dart.void, [dart.dynamic], [core.StackTrace]], |
2899 close: [dart.void, []] | 2894 close: [dart.void, []] |
2900 }) | 2895 }) |
2901 }); | 2896 }); |
2902 return _ControllerEventSinkWrapper; | 2897 return _ControllerEventSinkWrapper; |
2903 }); | 2898 }); |
2904 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); | 2899 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); |
2905 const __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart
.void, [StreamSubscription])); | 2900 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart
.void, [StreamSubscription])); |
2906 const __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart
.dynamic, [dart.dynamic, core.StackTrace])); | 2901 const __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart
.dynamic, [dart.dynamic, core.StackTrace])); |
2907 const __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart
.void, [])); | 2902 const __CastType15 = dart.typedef('__CastType15', () => dart.functionType(dart
.void, [])); |
2908 const __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart
.void, [EventSink])); | 2903 const __CastType16 = dart.typedef('__CastType16', () => dart.functionType(dart
.void, [EventSink])); |
2909 const StreamController$ = dart.generic(function(T) { | 2904 const StreamController$ = dart.generic(function(T) { |
2910 class StreamController extends core.Object { | 2905 class StreamController extends core.Object { |
2911 static new(opts) { | 2906 static new(opts) { |
2912 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2907 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
2913 let onPause = opts && 'onPause' in opts ? opts.onPause : null; | 2908 let onPause = opts && 'onPause' in opts ? opts.onPause : null; |
2914 let onResume = opts && 'onResume' in opts ? opts.onResume : null; | 2909 let onResume = opts && 'onResume' in opts ? opts.onResume : null; |
2915 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2910 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
2916 let sync = opts && 'sync' in opts ? opts.sync : false; | 2911 let sync = opts && 'sync' in opts ? opts.sync : false; |
2917 if (onListen == null && onPause == null && onResume == null && onCancel
== null) { | 2912 if (onListen == null && onPause == null && onResume == null && onCancel
== null) { |
2918 return dart.notNull(sync) ? new (_NoCallbackSyncStreamController$(T))(
) : new (_NoCallbackAsyncStreamController$(T))(); | 2913 return dart.notNull(sync) ? new (_NoCallbackSyncStreamController$(T))(
) : new (_NoCallbackAsyncStreamController$(T))(); |
(...skipping 401 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3320 } | 3315 } |
3321 } | 3316 } |
3322 return _NoCallbackSyncStreamController; | 3317 return _NoCallbackSyncStreamController; |
3323 }); | 3318 }); |
3324 let _NoCallbackSyncStreamController = _NoCallbackSyncStreamController$(); | 3319 let _NoCallbackSyncStreamController = _NoCallbackSyncStreamController$(); |
3325 const _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.f
unctionType(dart.dynamic, [])); | 3320 const _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.f
unctionType(dart.dynamic, [])); |
3326 function _runGuarded(notificationHandler) { | 3321 function _runGuarded(notificationHandler) { |
3327 if (notificationHandler == null) return null; | 3322 if (notificationHandler == null) return null; |
3328 try { | 3323 try { |
3329 let result = notificationHandler(); | 3324 let result = notificationHandler(); |
3330 if (dart.is(result, Future)) return dart.as(result, Future); | 3325 if (dart.is(result, Future)) return result; |
3331 return null; | 3326 return null; |
3332 } catch (e) { | 3327 } catch (e) { |
3333 let s = dart.stackTrace(e); | 3328 let s = dart.stackTrace(e); |
3334 Zone.current.handleUncaughtError(e, s); | 3329 Zone.current.handleUncaughtError(e, s); |
3335 } | 3330 } |
3336 | 3331 |
3337 } | 3332 } |
3338 dart.fn(_runGuarded, Future, [_NotificationHandler]); | 3333 dart.fn(_runGuarded, Future, [_NotificationHandler]); |
3339 const _target = Symbol('_target'); | 3334 const _target = Symbol('_target'); |
3340 const _StreamSinkWrapper$ = dart.generic(function(T) { | 3335 const _StreamSinkWrapper$ = dart.generic(function(T) { |
(...skipping 705 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4046 }); | 4041 }); |
4047 _StreamIteratorImpl._STATE_FOUND = 0; | 4042 _StreamIteratorImpl._STATE_FOUND = 0; |
4048 _StreamIteratorImpl._STATE_DONE = 1; | 4043 _StreamIteratorImpl._STATE_DONE = 1; |
4049 _StreamIteratorImpl._STATE_MOVING = 2; | 4044 _StreamIteratorImpl._STATE_MOVING = 2; |
4050 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 4045 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
4051 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 4046 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
4052 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 4047 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
4053 return _StreamIteratorImpl; | 4048 return _StreamIteratorImpl; |
4054 }); | 4049 }); |
4055 let _StreamIteratorImpl = _StreamIteratorImpl$(); | 4050 let _StreamIteratorImpl = _StreamIteratorImpl$(); |
4056 const __CastType20$ = dart.generic(function(T) { | 4051 const __CastType18$ = dart.generic(function(T) { |
4057 const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(da
rt.void, [T])); | 4052 const __CastType18 = dart.typedef('__CastType18', () => dart.functionType(da
rt.void, [T])); |
4058 return __CastType20; | 4053 return __CastType18; |
4059 }); | 4054 }); |
4060 let __CastType20 = __CastType20$(); | 4055 let __CastType18 = __CastType18$(); |
4061 const __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])); | 4056 const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])); |
4062 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart
.dynamic, [dart.dynamic])); | 4057 const __CastType23 = dart.typedef('__CastType23', () => dart.functionType(dart
.dynamic, [dart.dynamic])); |
4063 function _runUserCode(userCode, onSuccess, onError) { | 4058 function _runUserCode(userCode, onSuccess, onError) { |
4064 try { | 4059 try { |
4065 dart.dcall(onSuccess, userCode()); | 4060 dart.dcall(onSuccess, userCode()); |
4066 } catch (e) { | 4061 } catch (e) { |
4067 let s = dart.stackTrace(e); | 4062 let s = dart.stackTrace(e); |
4068 let replacement = Zone.current.errorCallback(e, s); | 4063 let replacement = Zone.current.errorCallback(e, s); |
4069 if (replacement == null) { | 4064 if (replacement == null) { |
4070 dart.dcall(onError, e, s); | 4065 dart.dcall(onError, e, s); |
4071 } else { | 4066 } else { |
4072 let error = _nonNullError(replacement.error); | 4067 let error = _nonNullError(replacement.error); |
(...skipping 697 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4770 }); | 4765 }); |
4771 let _HandlerEventSink = _HandlerEventSink$(); | 4766 let _HandlerEventSink = _HandlerEventSink$(); |
4772 const _StreamHandlerTransformer$ = dart.generic(function(S, T) { | 4767 const _StreamHandlerTransformer$ = dart.generic(function(S, T) { |
4773 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { | 4768 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { |
4774 _StreamHandlerTransformer(opts) { | 4769 _StreamHandlerTransformer(opts) { |
4775 let handleData = opts && 'handleData' in opts ? opts.handleData : null; | 4770 let handleData = opts && 'handleData' in opts ? opts.handleData : null; |
4776 let handleError = opts && 'handleError' in opts ? opts.handleError : nul
l; | 4771 let handleError = opts && 'handleError' in opts ? opts.handleError : nul
l; |
4777 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; | 4772 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; |
4778 super._StreamSinkTransformer(dart.fn(outputSink => { | 4773 super._StreamSinkTransformer(dart.fn(outputSink => { |
4779 dart.as(outputSink, EventSink$(T)); | 4774 dart.as(outputSink, EventSink$(T)); |
4780 if (handleData == null) handleData = dart.as(_StreamHandlerTransformer
$()._defaultHandleData, __CastType27); | 4775 if (handleData == null) handleData = dart.as(_StreamHandlerTransformer
$()._defaultHandleData, __CastType25); |
4781 if (handleError == null) handleError = dart.as(_StreamHandlerTransform
er$()._defaultHandleError, __CastType30); | 4776 if (handleError == null) handleError = dart.as(_StreamHandlerTransform
er$()._defaultHandleError, __CastType28); |
4782 if (handleDone == null) handleDone = _StreamHandlerTransformer$()._def
aultHandleDone; | 4777 if (handleDone == null) handleDone = _StreamHandlerTransformer$()._def
aultHandleDone; |
4783 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); | 4778 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); |
4784 }, EventSink$(S), [EventSink$(T)])); | 4779 }, EventSink$(S), [EventSink$(T)])); |
4785 } | 4780 } |
4786 bind(stream) { | 4781 bind(stream) { |
4787 dart.as(stream, Stream$(S)); | 4782 dart.as(stream, Stream$(S)); |
4788 return super.bind(stream); | 4783 return super.bind(stream); |
4789 } | 4784 } |
4790 static _defaultHandleData(data, sink) { | 4785 static _defaultHandleData(data, sink) { |
4791 sink.add(data); | 4786 sink.add(data); |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4855 return result; | 4850 return result; |
4856 } | 4851 } |
4857 } | 4852 } |
4858 dart.setSignature(_BoundSubscriptionStream, { | 4853 dart.setSignature(_BoundSubscriptionStream, { |
4859 constructors: () => ({_BoundSubscriptionStream: [_BoundSubscriptionStream$
(S, T), [Stream$(S), _SubscriptionTransformer$(S, T)]]}), | 4854 constructors: () => ({_BoundSubscriptionStream: [_BoundSubscriptionStream$
(S, T), [Stream$(S), _SubscriptionTransformer$(S, T)]]}), |
4860 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {onError: core.Function, onDone: dart.functionType(dart.void, []),
cancelOnError: core.bool}]}) | 4855 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {onError: core.Function, onDone: dart.functionType(dart.void, []),
cancelOnError: core.bool}]}) |
4861 }); | 4856 }); |
4862 return _BoundSubscriptionStream; | 4857 return _BoundSubscriptionStream; |
4863 }); | 4858 }); |
4864 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); | 4859 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); |
4865 const __CastType27$ = dart.generic(function(S, T) { | 4860 const __CastType25$ = dart.generic(function(S, T) { |
4866 const __CastType27 = dart.typedef('__CastType27', () => dart.functionType(da
rt.void, [S, EventSink$(T)])); | 4861 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(da
rt.void, [S, EventSink$(T)])); |
4867 return __CastType27; | 4862 return __CastType25; |
4868 }); | 4863 }); |
4869 let __CastType27 = __CastType27$(); | 4864 let __CastType25 = __CastType25$(); |
4870 const __CastType30$ = dart.generic(function(T) { | 4865 const __CastType28$ = dart.generic(function(T) { |
4871 const __CastType30 = dart.typedef('__CastType30', () => dart.functionType(da
rt.void, [core.Object, core.StackTrace, EventSink$(T)])); | 4866 const __CastType28 = dart.typedef('__CastType28', () => dart.functionType(da
rt.void, [core.Object, core.StackTrace, EventSink$(T)])); |
4872 return __CastType30; | 4867 return __CastType28; |
4873 }); | 4868 }); |
4874 let __CastType30 = __CastType30$(); | 4869 let __CastType28 = __CastType28$(); |
4875 class Timer extends core.Object { | 4870 class Timer extends core.Object { |
4876 static new(duration, callback) { | 4871 static new(duration, callback) { |
4877 if (dart.equals(Zone.current, Zone.ROOT)) { | 4872 if (dart.equals(Zone.current, Zone.ROOT)) { |
4878 return Zone.current.createTimer(duration, callback); | 4873 return Zone.current.createTimer(duration, callback); |
4879 } | 4874 } |
4880 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba
ck, {runGuarded: true})); | 4875 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba
ck, {runGuarded: true})); |
4881 } | 4876 } |
4882 static periodic(duration, callback) { | 4877 static periodic(duration, callback) { |
4883 if (dart.equals(Zone.current, Zone.ROOT)) { | 4878 if (dart.equals(Zone.current, Zone.ROOT)) { |
4884 return Zone.current.createPeriodicTimer(duration, callback); | 4879 return Zone.current.createPeriodicTimer(duration, callback); |
4885 } | 4880 } |
4886 return Zone.current.createPeriodicTimer(duration, dart.as(Zone.current.bin
dUnaryCallback(callback, {runGuarded: true}), __CastType34)); | 4881 return Zone.current.createPeriodicTimer(duration, dart.as(Zone.current.bin
dUnaryCallback(callback, {runGuarded: true}), __CastType32)); |
4887 } | 4882 } |
4888 static run(callback) { | 4883 static run(callback) { |
4889 Timer.new(core.Duration.ZERO, callback); | 4884 Timer.new(core.Duration.ZERO, callback); |
4890 } | 4885 } |
4891 static _createTimer(duration, callback) { | 4886 static _createTimer(duration, callback) { |
4892 let milliseconds = duration.inMilliseconds; | 4887 let milliseconds = duration.inMilliseconds; |
4893 if (dart.notNull(milliseconds) < 0) milliseconds = 0; | 4888 if (dart.notNull(milliseconds) < 0) milliseconds = 0; |
4894 return new _isolate_helper.TimerImpl(milliseconds, callback); | 4889 return new _isolate_helper.TimerImpl(milliseconds, callback); |
4895 } | 4890 } |
4896 static _createPeriodicTimer(duration, callback) { | 4891 static _createPeriodicTimer(duration, callback) { |
4897 let milliseconds = duration.inMilliseconds; | 4892 let milliseconds = duration.inMilliseconds; |
4898 if (dart.notNull(milliseconds) < 0) milliseconds = 0; | 4893 if (dart.notNull(milliseconds) < 0) milliseconds = 0; |
4899 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); | 4894 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); |
4900 } | 4895 } |
4901 } | 4896 } |
4902 dart.setSignature(Timer, { | 4897 dart.setSignature(Timer, { |
4903 constructors: () => ({ | 4898 constructors: () => ({ |
4904 new: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 4899 new: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
4905 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] | 4900 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] |
4906 }), | 4901 }), |
4907 statics: () => ({ | 4902 statics: () => ({ |
4908 run: [dart.void, [dart.functionType(dart.void, [])]], | 4903 run: [dart.void, [dart.functionType(dart.void, [])]], |
4909 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 4904 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
4910 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]] | 4905 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]] |
4911 }), | 4906 }), |
4912 names: ['run', '_createTimer', '_createPeriodicTimer'] | 4907 names: ['run', '_createTimer', '_createPeriodicTimer'] |
4913 }); | 4908 }); |
4914 const __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart
.void, [Timer])); | 4909 const __CastType32 = dart.typedef('__CastType32', () => dart.functionType(dart
.void, [Timer])); |
4915 const ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart
.dynamic, [])); | 4910 const ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart
.dynamic, [])); |
4916 const ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic])); | 4911 const ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic])); |
4917 const ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.funct
ionType(dart.dynamic, [dart.dynamic, dart.dynamic])); | 4912 const ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.funct
ionType(dart.dynamic, [dart.dynamic, dart.dynamic])); |
4918 const HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler',
() => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, c
ore.StackTrace])); | 4913 const HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler',
() => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, c
ore.StackTrace])); |
4919 const RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dyn
amic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | 4914 const RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dyn
amic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
4920 const RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionTyp
e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic]), dart.dynamic])); | 4915 const RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionTyp
e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic]), dart.dynamic])); |
4921 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])); | 4916 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])); |
4922 const RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () =>
dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dar
t.dynamic, [])])); | 4917 const RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () =>
dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dar
t.dynamic, [])])); |
4923 const RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandle
r', () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic])])); | 4918 const RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandle
r', () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic])])); |
4924 const RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHand
ler', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dar
t.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); | 4919 const RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHand
ler', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dar
t.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); |
(...skipping 23 matching lines...) Expand all Loading... |
4948 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 4943 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
4949 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 4944 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
4950 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 4945 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
4951 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; | 4946 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; |
4952 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; | 4947 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; |
4953 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; | 4948 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; |
4954 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; | 4949 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; |
4955 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; | 4950 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; |
4956 let print = opts && 'print' in opts ? opts.print : null; | 4951 let print = opts && 'print' in opts ? opts.print : null; |
4957 let fork = opts && 'fork' in opts ? opts.fork : null; | 4952 let fork = opts && 'fork' in opts ? opts.fork : null; |
4958 return ZoneSpecification.new({handleUncaughtError: dart.as(handleUncaughtE
rror != null ? handleUncaughtError : other.handleUncaughtError, __CastType36), r
un: dart.as(run != null ? run : other.run, __CastType42), runUnary: dart.as(runU
nary != null ? runUnary : other.runUnary, __CastType47), runBinary: dart.as(runB
inary != null ? runBinary : other.runBinary, __CastType54), registerCallback: da
rt.as(registerCallback != null ? registerCallback : other.registerCallback, __Ca
stType63), registerUnaryCallback: dart.as(registerUnaryCallback != null ? regist
erUnaryCallback : other.registerUnaryCallback, __CastType68), registerBinaryCall
back: dart.as(registerBinaryCallback != null ? registerBinaryCallback : other.re
gisterBinaryCallback, __CastType74), errorCallback: dart.as(errorCallback != nul
l ? errorCallback : other.errorCallback, __CastType81), scheduleMicrotask: dart.
as(scheduleMicrotask != null ? scheduleMicrotask : other.scheduleMicrotask, __Ca
stType87), createTimer: dart.as(createTimer != null ? createTimer : other.create
Timer, __CastType92), createPeriodicTimer: dart.as(createPeriodicTimer != null ?
createPeriodicTimer : other.createPeriodicTimer, __CastType98), print: dart.as(
print != null ? print : other.print, __CastType105), fork: dart.as(fork != null
? fork : other.fork, __CastType110)}); | 4953 return ZoneSpecification.new({handleUncaughtError: dart.as(handleUncaughtE
rror != null ? handleUncaughtError : other.handleUncaughtError, __CastType34), r
un: dart.as(run != null ? run : other.run, __CastType40), runUnary: dart.as(runU
nary != null ? runUnary : other.runUnary, __CastType45), runBinary: dart.as(runB
inary != null ? runBinary : other.runBinary, __CastType52), registerCallback: da
rt.as(registerCallback != null ? registerCallback : other.registerCallback, __Ca
stType61), registerUnaryCallback: dart.as(registerUnaryCallback != null ? regist
erUnaryCallback : other.registerUnaryCallback, __CastType66), registerBinaryCall
back: dart.as(registerBinaryCallback != null ? registerBinaryCallback : other.re
gisterBinaryCallback, __CastType72), errorCallback: dart.as(errorCallback != nul
l ? errorCallback : other.errorCallback, __CastType79), scheduleMicrotask: dart.
as(scheduleMicrotask != null ? scheduleMicrotask : other.scheduleMicrotask, __Ca
stType85), createTimer: dart.as(createTimer != null ? createTimer : other.create
Timer, __CastType90), createPeriodicTimer: dart.as(createPeriodicTimer != null ?
createPeriodicTimer : other.createPeriodicTimer, __CastType96), print: dart.as(
print != null ? print : other.print, __CastType103), fork: dart.as(fork != null
? fork : other.fork, __CastType108)}); |
4959 } | 4954 } |
4960 } | 4955 } |
4961 dart.setSignature(ZoneSpecification, { | 4956 dart.setSignature(ZoneSpecification, { |
4962 constructors: () => ({ | 4957 constructors: () => ({ |
4963 new: [ZoneSpecification, [], {handleUncaughtError: dart.functionType(dart.
dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]), run: dart.f
unctionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dyna
mic, [])]), runUnary: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone,
dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]), runBinary: dar
t.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), registerCal
lback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionT
ype(dart.dynamic, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCallb
ack, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic])]
), registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDele
gate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]), err
orCallback: dart.functionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]), scheduleMicrotask: dart.functionType(dart.void, [Zone, Zone
Delegate, Zone, dart.functionType(dart.dynamic, [])]), createTimer: dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])]), createPeriodicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zo
ne, core.Duration, dart.functionType(dart.void, [Timer])]), print: dart.function
Type(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork: dart.functionTyp
e(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}], | 4958 new: [ZoneSpecification, [], {handleUncaughtError: dart.functionType(dart.
dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]), run: dart.f
unctionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dyna
mic, [])]), runUnary: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone,
dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]), runBinary: dar
t.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), registerCal
lback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionT
ype(dart.dynamic, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCallb
ack, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic])]
), registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDele
gate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]), err
orCallback: dart.functionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]), scheduleMicrotask: dart.functionType(dart.void, [Zone, Zone
Delegate, Zone, dart.functionType(dart.dynamic, [])]), createTimer: dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])]), createPeriodicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zo
ne, core.Duration, dart.functionType(dart.void, [Timer])]), print: dart.function
Type(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork: dart.functionTyp
e(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}], |
4964 from: [ZoneSpecification, [ZoneSpecification], {handleUncaughtError: dart.
functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTr
ace]), run: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.func
tionType(dart.dynamic, [])]), runUnary: dart.functionType(dart.dynamic, [Zone, Z
oneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic
]), runBinary: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dyna
mic]), registerCallback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(dart.dynamic, [])]), registerUnaryCallback: dart.functionT
ype(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic
, [dart.dynamic])]), registerBinaryCallback: dart.functionType(ZoneBinaryCallbac
k, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dar
t.dynamic])]), errorCallback: dart.functionType(AsyncError, [Zone, ZoneDelegate,
Zone, core.Object, core.StackTrace]), scheduleMicrotask: dart.functionType(dart
.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]), createT
imer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.fu
nctionType(dart.void, [])]), createPeriodicTimer: dart.functionType(Timer, [Zone
, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [Timer])]), pr
int: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork
: dart.functionType(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map
])}] | 4959 from: [ZoneSpecification, [ZoneSpecification], {handleUncaughtError: dart.
functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTr
ace]), run: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.func
tionType(dart.dynamic, [])]), runUnary: dart.functionType(dart.dynamic, [Zone, Z
oneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic
]), runBinary: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dyna
mic]), registerCallback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(dart.dynamic, [])]), registerUnaryCallback: dart.functionT
ype(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic
, [dart.dynamic])]), registerBinaryCallback: dart.functionType(ZoneBinaryCallbac
k, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dar
t.dynamic])]), errorCallback: dart.functionType(AsyncError, [Zone, ZoneDelegate,
Zone, core.Object, core.StackTrace]), scheduleMicrotask: dart.functionType(dart
.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]), createT
imer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.fu
nctionType(dart.void, [])]), createPeriodicTimer: dart.functionType(Timer, [Zone
, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [Timer])]), pr
int: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork
: dart.functionType(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map
])}] |
4965 }) | 4960 }) |
4966 }); | 4961 }); |
4967 class _ZoneSpecification extends core.Object { | 4962 class _ZoneSpecification extends core.Object { |
4968 _ZoneSpecification(opts) { | 4963 _ZoneSpecification(opts) { |
(...skipping 468 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5437 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [])]); | 5432 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [])]); |
5438 function _rootCreateTimer(self, parent, zone, duration, callback) { | 5433 function _rootCreateTimer(self, parent, zone, duration, callback) { |
5439 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5434 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
5440 callback = zone.bindCallback(callback); | 5435 callback = zone.bindCallback(callback); |
5441 } | 5436 } |
5442 return Timer._createTimer(duration, callback); | 5437 return Timer._createTimer(duration, callback); |
5443 } | 5438 } |
5444 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); | 5439 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); |
5445 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { | 5440 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { |
5446 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5441 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
5447 callback = dart.as(zone.bindUnaryCallback(callback), __CastType116); | 5442 callback = dart.as(zone.bindUnaryCallback(callback), __CastType114); |
5448 } | 5443 } |
5449 return Timer._createPeriodicTimer(duration, callback); | 5444 return Timer._createPeriodicTimer(duration, callback); |
5450 } | 5445 } |
5451 dart.fn(_rootCreatePeriodicTimer, Timer, [Zone, ZoneDelegate, Zone, core.Durat
ion, dart.functionType(dart.void, [Timer])]); | 5446 dart.fn(_rootCreatePeriodicTimer, Timer, [Zone, ZoneDelegate, Zone, core.Durat
ion, dart.functionType(dart.void, [Timer])]); |
5452 function _rootPrint(self, parent, zone, line) { | 5447 function _rootPrint(self, parent, zone, line) { |
5453 _internal.printToConsole(line); | 5448 _internal.printToConsole(line); |
5454 } | 5449 } |
5455 dart.fn(_rootPrint, dart.void, [Zone, ZoneDelegate, Zone, core.String]); | 5450 dart.fn(_rootPrint, dart.void, [Zone, ZoneDelegate, Zone, core.String]); |
5456 function _printToZone(line) { | 5451 function _printToZone(line) { |
5457 Zone.current.print(line); | 5452 Zone.current.print(line); |
(...skipping 262 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5720 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 5715 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
5721 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; | 5716 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; |
5722 let onError = opts && 'onError' in opts ? opts.onError : null; | 5717 let onError = opts && 'onError' in opts ? opts.onError : null; |
5723 let errorHandler = null; | 5718 let errorHandler = null; |
5724 if (onError != null) { | 5719 if (onError != null) { |
5725 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { | 5720 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { |
5726 try { | 5721 try { |
5727 if (dart.is(onError, ZoneBinaryCallback)) { | 5722 if (dart.is(onError, ZoneBinaryCallback)) { |
5728 return self.parent.runBinary(onError, error, stackTrace); | 5723 return self.parent.runBinary(onError, error, stackTrace); |
5729 } | 5724 } |
5730 return self.parent.runUnary(dart.as(onError, __CastType118), error); | 5725 return self.parent.runUnary(dart.as(onError, __CastType116), error); |
5731 } catch (e) { | 5726 } catch (e) { |
5732 let s = dart.stackTrace(e); | 5727 let s = dart.stackTrace(e); |
5733 if (dart.notNull(core.identical(e, error))) { | 5728 if (dart.notNull(core.identical(e, error))) { |
5734 return parent.handleUncaughtError(zone, error, stackTrace); | 5729 return parent.handleUncaughtError(zone, error, stackTrace); |
5735 } else { | 5730 } else { |
5736 return parent.handleUncaughtError(zone, e, s); | 5731 return parent.handleUncaughtError(zone, e, s); |
5737 } | 5732 } |
5738 } | 5733 } |
5739 | 5734 |
5740 }, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]
); | 5735 }, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]
); |
5741 } | 5736 } |
5742 if (zoneSpecification == null) { | 5737 if (zoneSpecification == null) { |
5743 zoneSpecification = ZoneSpecification.new({handleUncaughtError: errorHandl
er}); | 5738 zoneSpecification = ZoneSpecification.new({handleUncaughtError: errorHandl
er}); |
5744 } else if (errorHandler != null) { | 5739 } else if (errorHandler != null) { |
5745 zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncau
ghtError: errorHandler}); | 5740 zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncau
ghtError: errorHandler}); |
5746 } | 5741 } |
5747 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); | 5742 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); |
5748 if (onError != null) { | 5743 if (onError != null) { |
5749 return zone.runGuarded(body); | 5744 return zone.runGuarded(body); |
5750 } else { | 5745 } else { |
5751 return zone.run(body); | 5746 return zone.run(body); |
5752 } | 5747 } |
5753 } | 5748 } |
5754 dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {zoneVa
lues: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); | 5749 dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {zoneVa
lues: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); |
5755 const __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace])); | 5750 const __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace])); |
5756 const __CastType42 = dart.typedef('__CastType42', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | 5751 const __CastType40 = dart.typedef('__CastType40', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
5757 const __CastType47 = dart.typedef('__CastType47', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynam
ic]), dart.dynamic])); | 5752 const __CastType45 = dart.typedef('__CastType45', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynam
ic]), dart.dynamic])); |
5758 const __CastType54 = dart.typedef('__CastType54', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynam
ic, dart.dynamic]), dart.dynamic, dart.dynamic])); | 5753 const __CastType52 = dart.typedef('__CastType52', () => dart.functionType(dart
.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynam
ic, dart.dynamic]), dart.dynamic, dart.dynamic])); |
5759 const __CastType63 = dart.typedef('__CastType63', () => dart.functionType(Zone
Callback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | 5754 const __CastType61 = dart.typedef('__CastType61', () => dart.functionType(Zone
Callback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
5760 const __CastType68 = dart.typedef('__CastType68', () => dart.functionType(Zone
UnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.
dynamic])])); | 5755 const __CastType66 = dart.typedef('__CastType66', () => dart.functionType(Zone
UnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.
dynamic])])); |
5761 const __CastType74 = dart.typedef('__CastType74', () => dart.functionType(Zone
BinaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic, dart.dynamic])])); | 5756 const __CastType72 = dart.typedef('__CastType72', () => dart.functionType(Zone
BinaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic, dart.dynamic])])); |
5762 const __CastType81 = dart.typedef('__CastType81', () => dart.functionType(Asyn
cError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace])); | 5757 const __CastType79 = dart.typedef('__CastType79', () => dart.functionType(Asyn
cError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace])); |
5763 const __CastType87 = dart.typedef('__CastType87', () => dart.functionType(dart
.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | 5758 const __CastType85 = dart.typedef('__CastType85', () => dart.functionType(dart
.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
5764 const __CastType92 = dart.typedef('__CastType92', () => dart.functionType(Time
r, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [])]))
; | 5759 const __CastType90 = dart.typedef('__CastType90', () => dart.functionType(Time
r, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [])]))
; |
5765 const __CastType98 = dart.typedef('__CastType98', () => dart.functionType(Time
r, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [Timer
])])); | 5760 const __CastType96 = dart.typedef('__CastType96', () => dart.functionType(Time
r, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [Timer
])])); |
5766 const __CastType105 = dart.typedef('__CastType105', () => dart.functionType(da
rt.void, [Zone, ZoneDelegate, Zone, core.String])); | 5761 const __CastType103 = dart.typedef('__CastType103', () => dart.functionType(da
rt.void, [Zone, ZoneDelegate, Zone, core.String])); |
5767 const __CastType110 = dart.typedef('__CastType110', () => dart.functionType(Zo
ne, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])); | 5762 const __CastType108 = dart.typedef('__CastType108', () => dart.functionType(Zo
ne, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])); |
5768 const __CastType116 = dart.typedef('__CastType116', () => dart.functionType(da
rt.void, [Timer])); | 5763 const __CastType114 = dart.typedef('__CastType114', () => dart.functionType(da
rt.void, [Timer])); |
5769 const __CastType118 = dart.typedef('__CastType118', () => dart.functionType(da
rt.dynamic, [dart.dynamic])); | 5764 const __CastType116 = dart.typedef('__CastType116', () => dart.functionType(da
rt.dynamic, [dart.dynamic])); |
5770 dart.copyProperties(exports, { | 5765 dart.copyProperties(exports, { |
5771 get _hasDocument() { | 5766 get _hasDocument() { |
5772 return typeof document == 'object'; | 5767 return typeof document == 'object'; |
5773 } | 5768 } |
5774 }); | 5769 }); |
5775 // Exports: | 5770 // Exports: |
5776 exports.AsyncError = AsyncError; | 5771 exports.AsyncError = AsyncError; |
5777 exports.Stream$ = Stream$; | 5772 exports.Stream$ = Stream$; |
5778 exports.Stream = Stream; | 5773 exports.Stream = Stream; |
5779 exports.DeferredLibrary = DeferredLibrary; | 5774 exports.DeferredLibrary = DeferredLibrary; |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5815 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5810 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5816 exports.CreateTimerHandler = CreateTimerHandler; | 5811 exports.CreateTimerHandler = CreateTimerHandler; |
5817 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5812 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5818 exports.PrintHandler = PrintHandler; | 5813 exports.PrintHandler = PrintHandler; |
5819 exports.ForkHandler = ForkHandler; | 5814 exports.ForkHandler = ForkHandler; |
5820 exports.ZoneSpecification = ZoneSpecification; | 5815 exports.ZoneSpecification = ZoneSpecification; |
5821 exports.ZoneDelegate = ZoneDelegate; | 5816 exports.ZoneDelegate = ZoneDelegate; |
5822 exports.Zone = Zone; | 5817 exports.Zone = Zone; |
5823 exports.runZoned = runZoned; | 5818 exports.runZoned = runZoned; |
5824 }); | 5819 }); |
OLD | NEW |