| OLD | NEW |
| 1 var async; | 1 var async; |
| 2 (function(exports) { | 2 (function(exports) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic | 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic |
| 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
| 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| 7 return dart.dinvokef(errorHandler, error, stackTrace); | 7 return dart.dcall(errorHandler, error, stackTrace); |
| 8 } else { | 8 } else { |
| 9 return dart.dinvokef(errorHandler, error); | 9 return dart.dcall(errorHandler, error); |
| 10 } | 10 } |
| 11 } | 11 } |
| 12 // Function _registerErrorHandler: (Function, Zone) → Function | 12 // Function _registerErrorHandler: (Function, Zone) → Function |
| 13 function _registerErrorHandler(errorHandler, zone) { | 13 function _registerErrorHandler(errorHandler, zone) { |
| 14 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 14 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| 15 return zone.registerBinaryCallback(errorHandler); | 15 return zone.registerBinaryCallback(errorHandler); |
| 16 } else { | 16 } else { |
| 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.functionType(
dart.dynamic, [dart.dynamic]))); | 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.functionType(
dart.dynamic, [dart.dynamic]))); |
| 18 } | 18 } |
| 19 } | 19 } |
| (...skipping 144 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 164 try { | 164 try { |
| 165 newValue = convert(event); | 165 newValue = convert(event); |
| 166 } catch (e) { | 166 } catch (e) { |
| 167 let s = dart.stackTrace(e); | 167 let s = dart.stackTrace(e); |
| 168 controller.addError(e, s); | 168 controller.addError(e, s); |
| 169 return; | 169 return; |
| 170 } | 170 } |
| 171 | 171 |
| 172 if (dart.is(newValue, Future)) { | 172 if (dart.is(newValue, Future)) { |
| 173 subscription.pause(); | 173 subscription.pause(); |
| 174 dart.dinvoke(dart.dinvoke(newValue, 'then', add, {onError: addErro
r}), 'whenComplete', subscription.resume); | 174 dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}),
'whenComplete', subscription.resume); |
| 175 } else { | 175 } else { |
| 176 controller.add(newValue); | 176 controller.add(newValue); |
| 177 } | 177 } |
| 178 }, {onError: dart.as(addError, core.Function), onDone: controller.clos
e}); | 178 }, {onError: dart.as(addError, core.Function), onDone: controller.clos
e}); |
| 179 } | 179 } |
| 180 if (this.isBroadcast) { | 180 if (this.isBroadcast) { |
| 181 controller = new StreamController.broadcast({ | 181 controller = new StreamController.broadcast({ |
| 182 onListen: onListen, | 182 onListen: onListen, |
| 183 onCancel: () => { | 183 onCancel: () => { |
| 184 subscription.cancel(); | 184 subscription.cancel(); |
| (...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 294 }, | 294 }, |
| 295 cancelOnError: true | 295 cancelOnError: true |
| 296 }); | 296 }); |
| 297 return result; | 297 return result; |
| 298 } | 298 } |
| 299 fold(initialValue, combine) { | 299 fold(initialValue, combine) { |
| 300 let result = new _Future(); | 300 let result = new _Future(); |
| 301 let value = initialValue; | 301 let value = initialValue; |
| 302 let subscription = null; | 302 let subscription = null; |
| 303 subscription = this.listen(element => { | 303 subscription = this.listen(element => { |
| 304 _runUserCode(() => dart.dinvokef(combine, value, element), newValue =>
{ | 304 _runUserCode(() => dart.dcall(combine, value, element), newValue => { |
| 305 value = newValue; | 305 value = newValue; |
| 306 }, dart.as(_cancelAndErrorClosure(subscription, result), dart.function
Type(dart.dynamic, [dart.dynamic, core.StackTrace]))); | 306 }, dart.as(_cancelAndErrorClosure(subscription, result), dart.function
Type(dart.dynamic, [dart.dynamic, core.StackTrace]))); |
| 307 }, { | 307 }, { |
| 308 onError: (e, st) => { | 308 onError: (e, st) => { |
| 309 result[_completeError](e, dart.as(st, core.StackTrace)); | 309 result[_completeError](e, dart.as(st, core.StackTrace)); |
| 310 }, | 310 }, |
| 311 onDone: () => { | 311 onDone: () => { |
| 312 result[_complete](value); | 312 result[_complete](value); |
| 313 }, | 313 }, |
| 314 cancelOnError: true | 314 cancelOnError: true |
| (...skipping 399 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 714 function onData(event) { | 714 function onData(event) { |
| 715 timer.cancel(); | 715 timer.cancel(); |
| 716 controller.add(event); | 716 controller.add(event); |
| 717 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); | 717 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); |
| 718 } | 718 } |
| 719 // Function onError: (dynamic, StackTrace) → void | 719 // Function onError: (dynamic, StackTrace) → void |
| 720 function onError(error, stackTrace) { | 720 function onError(error, stackTrace) { |
| 721 timer.cancel(); | 721 timer.cancel(); |
| 722 dart.assert(dart.notNull(dart.is(controller, _StreamController)) || da
rt.notNull(dart.is(controller, _BroadcastStreamController))); | 722 dart.assert(dart.notNull(dart.is(controller, _StreamController)) || da
rt.notNull(dart.is(controller, _BroadcastStreamController))); |
| 723 let eventSink = controller; | 723 let eventSink = controller; |
| 724 dart.dinvoke(eventSink, '_addError', error, stackTrace); | 724 dart.dsend(eventSink, '_addError', error, stackTrace); |
| 725 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); | 725 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); |
| 726 } | 726 } |
| 727 // Function onDone: () → void | 727 // Function onDone: () → void |
| 728 function onDone() { | 728 function onDone() { |
| 729 timer.cancel(); | 729 timer.cancel(); |
| 730 controller.close(); | 730 controller.close(); |
| 731 } | 731 } |
| 732 // Function onListen: () → void | 732 // Function onListen: () → void |
| 733 function onListen() { | 733 function onListen() { |
| 734 zone = Zone.current; | 734 zone = Zone.current; |
| (...skipping 407 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1142 if (dart.is(this[_cancelFuture], Future)) { | 1142 if (dart.is(this[_cancelFuture], Future)) { |
| 1143 this[_cancelFuture].whenComplete(sendDone); | 1143 this[_cancelFuture].whenComplete(sendDone); |
| 1144 } else { | 1144 } else { |
| 1145 sendDone(); | 1145 sendDone(); |
| 1146 } | 1146 } |
| 1147 } | 1147 } |
| 1148 [_guardCallback](callback) { | 1148 [_guardCallback](callback) { |
| 1149 dart.assert(!dart.notNull(this[_inCallback])); | 1149 dart.assert(!dart.notNull(this[_inCallback])); |
| 1150 let wasInputPaused = this[_isInputPaused]; | 1150 let wasInputPaused = this[_isInputPaused]; |
| 1151 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStrea
mSubscription[_STATE_IN_CALLBACK]); | 1151 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStrea
mSubscription[_STATE_IN_CALLBACK]); |
| 1152 dart.dinvokef(callback); | 1152 dart.dcall(callback); |
| 1153 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStre
amSubscription[_STATE_IN_CALLBACK]); | 1153 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStre
amSubscription[_STATE_IN_CALLBACK]); |
| 1154 this[_checkState](wasInputPaused); | 1154 this[_checkState](wasInputPaused); |
| 1155 } | 1155 } |
| 1156 [_checkState](wasInputPaused) { | 1156 [_checkState](wasInputPaused) { |
| 1157 dart.assert(!dart.notNull(this[_inCallback])); | 1157 dart.assert(!dart.notNull(this[_inCallback])); |
| 1158 if (dart.notNull(this[_hasPending]) && dart.notNull(this[_pending].isEmp
ty)) { | 1158 if (dart.notNull(this[_hasPending]) && dart.notNull(this[_pending].isEmp
ty)) { |
| 1159 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt
reamSubscription[_STATE_HAS_PENDING]); | 1159 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt
reamSubscription[_STATE_HAS_PENDING]); |
| 1160 if (dart.notNull(this[_isInputPaused]) && dart.notNull(this[_mayResume
Input])) { | 1160 if (dart.notNull(this[_isInputPaused]) && dart.notNull(this[_mayResume
Input])) { |
| 1161 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_Buffering
StreamSubscription[_STATE_INPUT_PAUSED]); | 1161 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_Buffering
StreamSubscription[_STATE_INPUT_PAUSED]); |
| 1162 } | 1162 } |
| (...skipping 589 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1752 let error = null; | 1752 let error = null; |
| 1753 let stackTrace = null; | 1753 let stackTrace = null; |
| 1754 // Function handleError: (dynamic, dynamic) → void | 1754 // Function handleError: (dynamic, dynamic) → void |
| 1755 function handleError(theError, theStackTrace) { | 1755 function handleError(theError, theStackTrace) { |
| 1756 remaining = dart.notNull(remaining) - 1; | 1756 remaining = dart.notNull(remaining) - 1; |
| 1757 if (values != null) { | 1757 if (values != null) { |
| 1758 if (cleanUp != null) { | 1758 if (cleanUp != null) { |
| 1759 for (let value of values) { | 1759 for (let value of values) { |
| 1760 if (value != null) { | 1760 if (value != null) { |
| 1761 new Future.sync(() => { | 1761 new Future.sync(() => { |
| 1762 dart.dinvokef(cleanUp, value); | 1762 dart.dcall(cleanUp, value); |
| 1763 }); | 1763 }); |
| 1764 } | 1764 } |
| 1765 } | 1765 } |
| 1766 } | 1766 } |
| 1767 values = null; | 1767 values = null; |
| 1768 if (remaining == 0 || dart.notNull(eagerError)) { | 1768 if (remaining == 0 || dart.notNull(eagerError)) { |
| 1769 result[_completeError](theError, dart.as(theStackTrace, core.Stack
Trace)); | 1769 result[_completeError](theError, dart.as(theStackTrace, core.Stack
Trace)); |
| 1770 } else { | 1770 } else { |
| 1771 error = theError; | 1771 error = theError; |
| 1772 stackTrace = dart.as(theStackTrace, core.StackTrace); | 1772 stackTrace = dart.as(theStackTrace, core.StackTrace); |
| 1773 } | 1773 } |
| 1774 } else if (remaining == 0 && !dart.notNull(eagerError)) { | 1774 } else if (remaining == 0 && !dart.notNull(eagerError)) { |
| 1775 result[_completeError](error, stackTrace); | 1775 result[_completeError](error, stackTrace); |
| 1776 } | 1776 } |
| 1777 } | 1777 } |
| 1778 for (let future of futures) { | 1778 for (let future of futures) { |
| 1779 let pos = remaining; | 1779 let pos = remaining; |
| 1780 remaining = dart.notNull(pos) + 1; | 1780 remaining = dart.notNull(pos) + 1; |
| 1781 future.then(value => { | 1781 future.then(value => { |
| 1782 remaining = dart.notNull(remaining) - 1; | 1782 remaining = dart.notNull(remaining) - 1; |
| 1783 if (values != null) { | 1783 if (values != null) { |
| 1784 values[core.$set](pos, value); | 1784 values[core.$set](pos, value); |
| 1785 if (remaining == 0) { | 1785 if (remaining == 0) { |
| 1786 result[_completeWithValue](values); | 1786 result[_completeWithValue](values); |
| 1787 } | 1787 } |
| 1788 } else { | 1788 } else { |
| 1789 if (dart.notNull(cleanUp != null) && dart.notNull(value != null))
{ | 1789 if (dart.notNull(cleanUp != null) && dart.notNull(value != null))
{ |
| 1790 new Future.sync(() => { | 1790 new Future.sync(() => { |
| 1791 dart.dinvokef(cleanUp, value); | 1791 dart.dcall(cleanUp, value); |
| 1792 }); | 1792 }); |
| 1793 } | 1793 } |
| 1794 if (remaining == 0 && !dart.notNull(eagerError)) { | 1794 if (remaining == 0 && !dart.notNull(eagerError)) { |
| 1795 result[_completeError](error, stackTrace); | 1795 result[_completeError](error, stackTrace); |
| 1796 } | 1796 } |
| 1797 } | 1797 } |
| 1798 }, {onError: handleError}); | 1798 }, {onError: handleError}); |
| 1799 } | 1799 } |
| 1800 if (remaining == 0) { | 1800 if (remaining == 0) { |
| 1801 return dart.as(new Future.value(/* Unimplemented const */new core.List
.from([])), Future$(core.List)); | 1801 return dart.as(new Future.value(/* Unimplemented const */new core.List
.from([])), Future$(core.List)); |
| 1802 } | 1802 } |
| 1803 values = new core.List(remaining); | 1803 values = new core.List(remaining); |
| 1804 return result; | 1804 return result; |
| 1805 } | 1805 } |
| 1806 static forEach(input, f) { | 1806 static forEach(input, f) { |
| 1807 let iterator = input[core.$iterator]; | 1807 let iterator = input[core.$iterator]; |
| 1808 return Future.doWhile(() => { | 1808 return Future.doWhile(() => { |
| 1809 if (!dart.notNull(iterator.moveNext())) | 1809 if (!dart.notNull(iterator.moveNext())) |
| 1810 return false; | 1810 return false; |
| 1811 return new Future.sync(() => dart.dinvokef(f, iterator.current)).then(
_ => true); | 1811 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ =
> true); |
| 1812 }); | 1812 }); |
| 1813 } | 1813 } |
| 1814 static doWhile(f) { | 1814 static doWhile(f) { |
| 1815 let doneSignal = new _Future(); | 1815 let doneSignal = new _Future(); |
| 1816 let nextIteration = null; | 1816 let nextIteration = null; |
| 1817 nextIteration = Zone.current.bindUnaryCallback(keepGoing => { | 1817 nextIteration = Zone.current.bindUnaryCallback(keepGoing => { |
| 1818 if (keepGoing) { | 1818 if (keepGoing) { |
| 1819 new Future.sync(f).then(dart.as(nextIteration, dart.functionType(dar
t.dynamic, [dart.dynamic])), {onError: doneSignal[_completeError]}); | 1819 new Future.sync(f).then(dart.as(nextIteration, dart.functionType(dar
t.dynamic, [dart.dynamic])), {onError: doneSignal[_completeError]}); |
| 1820 } else { | 1820 } else { |
| 1821 doneSignal[_complete](null); | 1821 doneSignal[_complete](null); |
| 1822 } | 1822 } |
| 1823 }, {runGuarded: true}); | 1823 }, {runGuarded: true}); |
| 1824 dart.dinvokef(nextIteration, true); | 1824 dart.dcall(nextIteration, true); |
| 1825 return doneSignal; | 1825 return doneSignal; |
| 1826 } | 1826 } |
| 1827 } | 1827 } |
| 1828 dart.defineNamedConstructor(Future, 'microtask'); | 1828 dart.defineNamedConstructor(Future, 'microtask'); |
| 1829 dart.defineNamedConstructor(Future, 'sync'); | 1829 dart.defineNamedConstructor(Future, 'sync'); |
| 1830 dart.defineNamedConstructor(Future, 'value'); | 1830 dart.defineNamedConstructor(Future, 'value'); |
| 1831 dart.defineNamedConstructor(Future, 'error'); | 1831 dart.defineNamedConstructor(Future, 'error'); |
| 1832 dart.defineNamedConstructor(Future, 'delayed'); | 1832 dart.defineNamedConstructor(Future, 'delayed'); |
| 1833 dart.defineLazyProperties(Future, { | 1833 dart.defineLazyProperties(Future, { |
| 1834 get _nullFuture() { | 1834 get _nullFuture() { |
| (...skipping 526 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2361 listenerValueOrError = new AsyncError(e, s); | 2361 listenerValueOrError = new AsyncError(e, s); |
| 2362 } | 2362 } |
| 2363 listenerHasValue = false; | 2363 listenerHasValue = false; |
| 2364 return; | 2364 return; |
| 2365 } | 2365 } |
| 2366 | 2366 |
| 2367 if (dart.is(completeResult, Future)) { | 2367 if (dart.is(completeResult, Future)) { |
| 2368 let result = listener.result; | 2368 let result = listener.result; |
| 2369 result[_isChained] = true; | 2369 result[_isChained] = true; |
| 2370 isPropagationAborted = true; | 2370 isPropagationAborted = true; |
| 2371 dart.dinvoke(completeResult, 'then', ignored => { | 2371 dart.dsend(completeResult, 'then', ignored => { |
| 2372 _Future[_propagateToListeners](source, new _FutureListener.cha
in(result)); | 2372 _Future[_propagateToListeners](source, new _FutureListener.cha
in(result)); |
| 2373 }, { | 2373 }, { |
| 2374 onError: (error, stackTrace) => { | 2374 onError: (error, stackTrace) => { |
| 2375 if (stackTrace === void 0) | 2375 if (stackTrace === void 0) |
| 2376 stackTrace = null; | 2376 stackTrace = null; |
| 2377 if (!dart.is(completeResult, _Future)) { | 2377 if (!dart.is(completeResult, _Future)) { |
| 2378 completeResult = new _Future(); | 2378 completeResult = new _Future(); |
| 2379 dart.dinvoke(completeResult, '_setError', error, stackTrac
e); | 2379 dart.dsend(completeResult, '_setError', error, stackTrace)
; |
| 2380 } | 2380 } |
| 2381 _Future[_propagateToListeners](dart.as(completeResult, _Futu
re), new _FutureListener.chain(result)); | 2381 _Future[_propagateToListeners](dart.as(completeResult, _Futu
re), new _FutureListener.chain(result)); |
| 2382 } | 2382 } |
| 2383 }); | 2383 }); |
| 2384 } | 2384 } |
| 2385 } | 2385 } |
| 2386 if (!dart.notNull(hasError)) { | 2386 if (!dart.notNull(hasError)) { |
| 2387 if (listener.handlesValue) { | 2387 if (listener.handlesValue) { |
| 2388 listenerHasValue = handleValueCallback(); | 2388 listenerHasValue = handleValueCallback(); |
| 2389 } | 2389 } |
| (...skipping 160 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2550 } | 2550 } |
| 2551 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); | 2551 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); |
| 2552 } | 2552 } |
| 2553 let _initializeScheduleImmediate = Symbol('_initializeScheduleImmediate'); | 2553 let _initializeScheduleImmediate = Symbol('_initializeScheduleImmediate'); |
| 2554 let _scheduleImmediateJsOverride = Symbol('_scheduleImmediateJsOverride'); | 2554 let _scheduleImmediateJsOverride = Symbol('_scheduleImmediateJsOverride'); |
| 2555 let _scheduleImmediateWithSetImmediate = Symbol('_scheduleImmediateWithSetImme
diate'); | 2555 let _scheduleImmediateWithSetImmediate = Symbol('_scheduleImmediateWithSetImme
diate'); |
| 2556 let _scheduleImmediateWithTimer = Symbol('_scheduleImmediateWithTimer'); | 2556 let _scheduleImmediateWithTimer = Symbol('_scheduleImmediateWithTimer'); |
| 2557 let _createTimer = Symbol('_createTimer'); | 2557 let _createTimer = Symbol('_createTimer'); |
| 2558 class _AsyncRun extends core.Object { | 2558 class _AsyncRun extends core.Object { |
| 2559 static [_scheduleImmediate](callback) { | 2559 static [_scheduleImmediate](callback) { |
| 2560 dart.dinvokef(_AsyncRun.scheduleImmediateClosure, callback); | 2560 dart.dcall(_AsyncRun.scheduleImmediateClosure, callback); |
| 2561 } | 2561 } |
| 2562 static [_initializeScheduleImmediate]() { | 2562 static [_initializeScheduleImmediate]() { |
| 2563 _js_helper.requiresPreamble(); | 2563 _js_helper.requiresPreamble(); |
| 2564 if (self.scheduleImmediate != null) { | 2564 if (self.scheduleImmediate != null) { |
| 2565 return _AsyncRun[_scheduleImmediateJsOverride]; | 2565 return _AsyncRun[_scheduleImmediateJsOverride]; |
| 2566 } | 2566 } |
| 2567 if (dart.notNull(self.MutationObserver != null) && dart.notNull(self.docum
ent != null)) { | 2567 if (dart.notNull(self.MutationObserver != null) && dart.notNull(self.docum
ent != null)) { |
| 2568 let div = self.document.createElement("div"); | 2568 let div = self.document.createElement("div"); |
| 2569 let span = self.document.createElement("span"); | 2569 let span = self.document.createElement("span"); |
| 2570 let storedCallback = null; | 2570 let storedCallback = null; |
| 2571 // Function internalCallback: (dynamic) → dynamic | 2571 // Function internalCallback: (dynamic) → dynamic |
| 2572 function internalCallback(_) { | 2572 function internalCallback(_) { |
| 2573 _isolate_helper.leaveJsAsync(); | 2573 _isolate_helper.leaveJsAsync(); |
| 2574 let f = storedCallback; | 2574 let f = storedCallback; |
| 2575 storedCallback = null; | 2575 storedCallback = null; |
| 2576 dart.dinvokef(f); | 2576 dart.dcall(f); |
| 2577 } | 2577 } |
| 2578 ; | 2578 ; |
| 2579 let observer = new self.MutationObserver(_js_helper.convertDartClosureTo
JS(internalCallback, 1)); | 2579 let observer = new self.MutationObserver(_js_helper.convertDartClosureTo
JS(internalCallback, 1)); |
| 2580 observer.observe(div, {childList: true}); | 2580 observer.observe(div, {childList: true}); |
| 2581 return callback => { | 2581 return callback => { |
| 2582 dart.assert(storedCallback == null); | 2582 dart.assert(storedCallback == null); |
| 2583 _isolate_helper.enterJsAsync(); | 2583 _isolate_helper.enterJsAsync(); |
| 2584 storedCallback = callback; | 2584 storedCallback = callback; |
| 2585 div.firstChild ? div.removeChild(span) : div.appendChild(span); | 2585 div.firstChild ? div.removeChild(span) : div.appendChild(span); |
| 2586 }; | 2586 }; |
| (...skipping 1096 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3683 _StreamIteratorImpl._STATE_MOVING = 2; | 3683 _StreamIteratorImpl._STATE_MOVING = 2; |
| 3684 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 3684 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
| 3685 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 3685 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
| 3686 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 3686 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
| 3687 return _StreamIteratorImpl; | 3687 return _StreamIteratorImpl; |
| 3688 }); | 3688 }); |
| 3689 let _StreamIteratorImpl = _StreamIteratorImpl$(); | 3689 let _StreamIteratorImpl = _StreamIteratorImpl$(); |
| 3690 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT
race) → dynamic) → dynamic | 3690 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT
race) → dynamic) → dynamic |
| 3691 function _runUserCode(userCode, onSuccess, onError) { | 3691 function _runUserCode(userCode, onSuccess, onError) { |
| 3692 try { | 3692 try { |
| 3693 dart.dinvokef(onSuccess, userCode()); | 3693 dart.dcall(onSuccess, userCode()); |
| 3694 } catch (e) { | 3694 } catch (e) { |
| 3695 let s = dart.stackTrace(e); | 3695 let s = dart.stackTrace(e); |
| 3696 let replacement = Zone.current.errorCallback(e, s); | 3696 let replacement = Zone.current.errorCallback(e, s); |
| 3697 if (replacement == null) { | 3697 if (replacement == null) { |
| 3698 dart.dinvokef(onError, e, s); | 3698 dart.dcall(onError, e, s); |
| 3699 } else { | 3699 } else { |
| 3700 let error = _nonNullError(replacement.error); | 3700 let error = _nonNullError(replacement.error); |
| 3701 let stackTrace = replacement.stackTrace; | 3701 let stackTrace = replacement.stackTrace; |
| 3702 dart.dinvokef(onError, error, stackTrace); | 3702 dart.dcall(onError, error, stackTrace); |
| 3703 } | 3703 } |
| 3704 } | 3704 } |
| 3705 | 3705 |
| 3706 } | 3706 } |
| 3707 // Function _cancelAndError: (StreamSubscription<dynamic>, _Future<dynamic>, d
ynamic, StackTrace) → void | 3707 // Function _cancelAndError: (StreamSubscription<dynamic>, _Future<dynamic>, d
ynamic, StackTrace) → void |
| 3708 function _cancelAndError(subscription, future, error, stackTrace) { | 3708 function _cancelAndError(subscription, future, error, stackTrace) { |
| 3709 let cancelFuture = subscription.cancel(); | 3709 let cancelFuture = subscription.cancel(); |
| 3710 if (dart.is(cancelFuture, Future)) { | 3710 if (dart.is(cancelFuture, Future)) { |
| 3711 cancelFuture.whenComplete(() => future[_completeError](error, stackTrace))
; | 3711 cancelFuture.whenComplete(() => future[_completeError](error, stackTrace))
; |
| 3712 } else { | 3712 } else { |
| (...skipping 154 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3867 let _transform = Symbol('_transform'); | 3867 let _transform = Symbol('_transform'); |
| 3868 let _MapStream$ = dart.generic(function(S, T) { | 3868 let _MapStream$ = dart.generic(function(S, T) { |
| 3869 class _MapStream extends _ForwardingStream$(S, T) { | 3869 class _MapStream extends _ForwardingStream$(S, T) { |
| 3870 _MapStream(source, transform) { | 3870 _MapStream(source, transform) { |
| 3871 this[_transform] = transform; | 3871 this[_transform] = transform; |
| 3872 super._ForwardingStream(source); | 3872 super._ForwardingStream(source); |
| 3873 } | 3873 } |
| 3874 [_handleData](inputEvent, sink) { | 3874 [_handleData](inputEvent, sink) { |
| 3875 let outputEvent = null; | 3875 let outputEvent = null; |
| 3876 try { | 3876 try { |
| 3877 outputEvent = dart.as(dart.dinvokef(this[_transform], inputEvent), T); | 3877 outputEvent = dart.as(dart.dcall(this[_transform], inputEvent), T); |
| 3878 } catch (e) { | 3878 } catch (e) { |
| 3879 let s = dart.stackTrace(e); | 3879 let s = dart.stackTrace(e); |
| 3880 _addErrorWithReplacement(sink, e, s); | 3880 _addErrorWithReplacement(sink, e, s); |
| 3881 return; | 3881 return; |
| 3882 } | 3882 } |
| 3883 | 3883 |
| 3884 sink[_add](outputEvent); | 3884 sink[_add](outputEvent); |
| 3885 } | 3885 } |
| 3886 } | 3886 } |
| 3887 return _MapStream; | 3887 return _MapStream; |
| (...skipping 26 matching lines...) Expand all Loading... |
| 3914 class _HandleErrorStream extends _ForwardingStream$(T, T) { | 3914 class _HandleErrorStream extends _ForwardingStream$(T, T) { |
| 3915 _HandleErrorStream(source, onError, test) { | 3915 _HandleErrorStream(source, onError, test) { |
| 3916 this[_transform] = onError; | 3916 this[_transform] = onError; |
| 3917 this[_test] = test; | 3917 this[_test] = test; |
| 3918 super._ForwardingStream(source); | 3918 super._ForwardingStream(source); |
| 3919 } | 3919 } |
| 3920 [_handleError](error, stackTrace, sink) { | 3920 [_handleError](error, stackTrace, sink) { |
| 3921 let matches = true; | 3921 let matches = true; |
| 3922 if (this[_test] != null) { | 3922 if (this[_test] != null) { |
| 3923 try { | 3923 try { |
| 3924 matches = dart.dinvokef(this[_test], error); | 3924 matches = dart.dcall(this[_test], error); |
| 3925 } catch (e) { | 3925 } catch (e) { |
| 3926 let s = dart.stackTrace(e); | 3926 let s = dart.stackTrace(e); |
| 3927 _addErrorWithReplacement(sink, e, s); | 3927 _addErrorWithReplacement(sink, e, s); |
| 3928 return; | 3928 return; |
| 3929 } | 3929 } |
| 3930 | 3930 |
| 3931 } | 3931 } |
| 3932 if (matches) { | 3932 if (matches) { |
| 3933 try { | 3933 try { |
| 3934 _invokeErrorHandler(this[_transform], error, stackTrace); | 3934 _invokeErrorHandler(this[_transform], error, stackTrace); |
| (...skipping 575 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4510 let _scheduleMicrotask = Symbol('_scheduleMicrotask'); | 4510 let _scheduleMicrotask = Symbol('_scheduleMicrotask'); |
| 4511 let _print = Symbol('_print'); | 4511 let _print = Symbol('_print'); |
| 4512 let _fork = Symbol('_fork'); | 4512 let _fork = Symbol('_fork'); |
| 4513 class _ZoneDelegate extends core.Object { | 4513 class _ZoneDelegate extends core.Object { |
| 4514 _ZoneDelegate(delegationTarget) { | 4514 _ZoneDelegate(delegationTarget) { |
| 4515 this[_delegationTarget] = delegationTarget; | 4515 this[_delegationTarget] = delegationTarget; |
| 4516 } | 4516 } |
| 4517 handleUncaughtError(zone, error, stackTrace) { | 4517 handleUncaughtError(zone, error, stackTrace) { |
| 4518 let implementation = this[_delegationTarget][_handleUncaughtError]; | 4518 let implementation = this[_delegationTarget][_handleUncaughtError]; |
| 4519 let implZone = implementation.zone; | 4519 let implZone = implementation.zone; |
| 4520 return dart.dinvokef(implementation.function, implZone, _parentDelegate(im
plZone), zone, error, stackTrace); | 4520 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ
one), zone, error, stackTrace); |
| 4521 } | 4521 } |
| 4522 run(zone, f) { | 4522 run(zone, f) { |
| 4523 let implementation = this[_delegationTarget][_run]; | 4523 let implementation = this[_delegationTarget][_run]; |
| 4524 let implZone = implementation.zone; | 4524 let implZone = implementation.zone; |
| 4525 return dart.dinvokef(implementation.function, implZone, _parentDelegate(im
plZone), zone, f); | 4525 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ
one), zone, f); |
| 4526 } | 4526 } |
| 4527 runUnary(zone, f, arg) { | 4527 runUnary(zone, f, arg) { |
| 4528 let implementation = this[_delegationTarget][_runUnary]; | 4528 let implementation = this[_delegationTarget][_runUnary]; |
| 4529 let implZone = implementation.zone; | 4529 let implZone = implementation.zone; |
| 4530 return dart.dinvokef(implementation.function, implZone, _parentDelegate(im
plZone), zone, f, arg); | 4530 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ
one), zone, f, arg); |
| 4531 } | 4531 } |
| 4532 runBinary(zone, f, arg1, arg2) { | 4532 runBinary(zone, f, arg1, arg2) { |
| 4533 let implementation = this[_delegationTarget][_runBinary]; | 4533 let implementation = this[_delegationTarget][_runBinary]; |
| 4534 let implZone = implementation.zone; | 4534 let implZone = implementation.zone; |
| 4535 return dart.dinvokef(implementation.function, implZone, _parentDelegate(im
plZone), zone, f, arg1, arg2); | 4535 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ
one), zone, f, arg1, arg2); |
| 4536 } | 4536 } |
| 4537 registerCallback(zone, f) { | 4537 registerCallback(zone, f) { |
| 4538 let implementation = this[_delegationTarget][_registerCallback]; | 4538 let implementation = this[_delegationTarget][_registerCallback]; |
| 4539 let implZone = implementation.zone; | 4539 let implZone = implementation.zone; |
| 4540 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, f), ZoneCallback); | 4540 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, f), ZoneCallback); |
| 4541 } | 4541 } |
| 4542 registerUnaryCallback(zone, f) { | 4542 registerUnaryCallback(zone, f) { |
| 4543 let implementation = this[_delegationTarget][_registerUnaryCallback]; | 4543 let implementation = this[_delegationTarget][_registerUnaryCallback]; |
| 4544 let implZone = implementation.zone; | 4544 let implZone = implementation.zone; |
| 4545 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, f), ZoneUnaryCallback); | 4545 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, f), ZoneUnaryCallback); |
| 4546 } | 4546 } |
| 4547 registerBinaryCallback(zone, f) { | 4547 registerBinaryCallback(zone, f) { |
| 4548 let implementation = this[_delegationTarget][_registerBinaryCallback]; | 4548 let implementation = this[_delegationTarget][_registerBinaryCallback]; |
| 4549 let implZone = implementation.zone; | 4549 let implZone = implementation.zone; |
| 4550 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, f), ZoneBinaryCallback); | 4550 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, f), ZoneBinaryCallback); |
| 4551 } | 4551 } |
| 4552 errorCallback(zone, error, stackTrace) { | 4552 errorCallback(zone, error, stackTrace) { |
| 4553 let implementation = this[_delegationTarget][_errorCallback]; | 4553 let implementation = this[_delegationTarget][_errorCallback]; |
| 4554 let implZone = implementation.zone; | 4554 let implZone = implementation.zone; |
| 4555 if (core.identical(implZone, _ROOT_ZONE)) | 4555 if (core.identical(implZone, _ROOT_ZONE)) |
| 4556 return null; | 4556 return null; |
| 4557 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, error, stackTrace), AsyncError); | 4557 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, error, stackTrace), AsyncError); |
| 4558 } | 4558 } |
| 4559 scheduleMicrotask(zone, f) { | 4559 scheduleMicrotask(zone, f) { |
| 4560 let implementation = this[_delegationTarget][_scheduleMicrotask]; | 4560 let implementation = this[_delegationTarget][_scheduleMicrotask]; |
| 4561 let implZone = implementation.zone; | 4561 let implZone = implementation.zone; |
| 4562 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone)
, zone, f); | 4562 dart.dcall(implementation.function, implZone, _parentDelegate(implZone), z
one, f); |
| 4563 } | 4563 } |
| 4564 createTimer(zone, duration, f) { | 4564 createTimer(zone, duration, f) { |
| 4565 let implementation = this[_delegationTarget][_createTimer]; | 4565 let implementation = this[_delegationTarget][_createTimer]; |
| 4566 let implZone = implementation.zone; | 4566 let implZone = implementation.zone; |
| 4567 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, duration, f), Timer); | 4567 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, duration, f), Timer); |
| 4568 } | 4568 } |
| 4569 createPeriodicTimer(zone, period, f) { | 4569 createPeriodicTimer(zone, period, f) { |
| 4570 let implementation = this[_delegationTarget][_createPeriodicTimer]; | 4570 let implementation = this[_delegationTarget][_createPeriodicTimer]; |
| 4571 let implZone = implementation.zone; | 4571 let implZone = implementation.zone; |
| 4572 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, period, f), Timer); | 4572 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, period, f), Timer); |
| 4573 } | 4573 } |
| 4574 print(zone, line) { | 4574 print(zone, line) { |
| 4575 let implementation = this[_delegationTarget][_print]; | 4575 let implementation = this[_delegationTarget][_print]; |
| 4576 let implZone = implementation.zone; | 4576 let implZone = implementation.zone; |
| 4577 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone)
, zone, line); | 4577 dart.dcall(implementation.function, implZone, _parentDelegate(implZone), z
one, line); |
| 4578 } | 4578 } |
| 4579 fork(zone, specification, zoneValues) { | 4579 fork(zone, specification, zoneValues) { |
| 4580 let implementation = this[_delegationTarget][_fork]; | 4580 let implementation = this[_delegationTarget][_fork]; |
| 4581 let implZone = implementation.zone; | 4581 let implZone = implementation.zone; |
| 4582 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, specification, zoneValues), Zone); | 4582 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, specification, zoneValues), Zone); |
| 4583 } | 4583 } |
| 4584 } | 4584 } |
| 4585 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; | 4585 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; |
| 4586 class _Zone extends core.Object { | 4586 class _Zone extends core.Object { |
| 4587 _Zone() { | 4587 _Zone() { |
| 4588 } | 4588 } |
| 4589 inSameErrorZone(otherZone) { | 4589 inSameErrorZone(otherZone) { |
| 4590 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); | 4590 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); |
| 4591 } | 4591 } |
| 4592 } | 4592 } |
| (...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4700 } | 4700 } |
| 4701 return value; | 4701 return value; |
| 4702 } | 4702 } |
| 4703 dart.assert(dart.equals(this, _ROOT_ZONE)); | 4703 dart.assert(dart.equals(this, _ROOT_ZONE)); |
| 4704 return null; | 4704 return null; |
| 4705 } | 4705 } |
| 4706 handleUncaughtError(error, stackTrace) { | 4706 handleUncaughtError(error, stackTrace) { |
| 4707 let implementation = this[_handleUncaughtError]; | 4707 let implementation = this[_handleUncaughtError]; |
| 4708 dart.assert(implementation != null); | 4708 dart.assert(implementation != null); |
| 4709 let parentDelegate = _parentDelegate(implementation.zone); | 4709 let parentDelegate = _parentDelegate(implementation.zone); |
| 4710 return dart.dinvokef(implementation.function, implementation.zone, parentD
elegate, this, error, stackTrace); | 4710 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, error, stackTrace); |
| 4711 } | 4711 } |
| 4712 fork(opts) { | 4712 fork(opts) { |
| 4713 let specification = opts && 'specification' in opts ? opts.specification :
null; | 4713 let specification = opts && 'specification' in opts ? opts.specification :
null; |
| 4714 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 4714 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
| 4715 let implementation = this[_fork]; | 4715 let implementation = this[_fork]; |
| 4716 dart.assert(implementation != null); | 4716 dart.assert(implementation != null); |
| 4717 let parentDelegate = _parentDelegate(implementation.zone); | 4717 let parentDelegate = _parentDelegate(implementation.zone); |
| 4718 return dart.as(dart.dinvokef(implementation.function, implementation.zone,
parentDelegate, this, specification, zoneValues), Zone); | 4718 return dart.as(dart.dcall(implementation.function, implementation.zone, pa
rentDelegate, this, specification, zoneValues), Zone); |
| 4719 } | 4719 } |
| 4720 run(f) { | 4720 run(f) { |
| 4721 let implementation = this[_run]; | 4721 let implementation = this[_run]; |
| 4722 dart.assert(implementation != null); | 4722 dart.assert(implementation != null); |
| 4723 let parentDelegate = _parentDelegate(implementation.zone); | 4723 let parentDelegate = _parentDelegate(implementation.zone); |
| 4724 return dart.dinvokef(implementation.function, implementation.zone, parentD
elegate, this, f); | 4724 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, f); |
| 4725 } | 4725 } |
| 4726 runUnary(f, arg) { | 4726 runUnary(f, arg) { |
| 4727 let implementation = this[_runUnary]; | 4727 let implementation = this[_runUnary]; |
| 4728 dart.assert(implementation != null); | 4728 dart.assert(implementation != null); |
| 4729 let parentDelegate = _parentDelegate(implementation.zone); | 4729 let parentDelegate = _parentDelegate(implementation.zone); |
| 4730 return dart.dinvokef(implementation.function, implementation.zone, parentD
elegate, this, f, arg); | 4730 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, f, arg); |
| 4731 } | 4731 } |
| 4732 runBinary(f, arg1, arg2) { | 4732 runBinary(f, arg1, arg2) { |
| 4733 let implementation = this[_runBinary]; | 4733 let implementation = this[_runBinary]; |
| 4734 dart.assert(implementation != null); | 4734 dart.assert(implementation != null); |
| 4735 let parentDelegate = _parentDelegate(implementation.zone); | 4735 let parentDelegate = _parentDelegate(implementation.zone); |
| 4736 return dart.dinvokef(implementation.function, implementation.zone, parentD
elegate, this, f, arg1, arg2); | 4736 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, f, arg1, arg2); |
| 4737 } | 4737 } |
| 4738 registerCallback(f) { | 4738 registerCallback(f) { |
| 4739 let implementation = this[_registerCallback]; | 4739 let implementation = this[_registerCallback]; |
| 4740 dart.assert(implementation != null); | 4740 dart.assert(implementation != null); |
| 4741 let parentDelegate = _parentDelegate(implementation.zone); | 4741 let parentDelegate = _parentDelegate(implementation.zone); |
| 4742 return dart.as(dart.dinvokef(implementation.function, implementation.zone,
parentDelegate, this, f), ZoneCallback); | 4742 return dart.as(dart.dcall(implementation.function, implementation.zone, pa
rentDelegate, this, f), ZoneCallback); |
| 4743 } | 4743 } |
| 4744 registerUnaryCallback(f) { | 4744 registerUnaryCallback(f) { |
| 4745 let implementation = this[_registerUnaryCallback]; | 4745 let implementation = this[_registerUnaryCallback]; |
| 4746 dart.assert(implementation != null); | 4746 dart.assert(implementation != null); |
| 4747 let parentDelegate = _parentDelegate(implementation.zone); | 4747 let parentDelegate = _parentDelegate(implementation.zone); |
| 4748 return dart.as(dart.dinvokef(implementation.function, implementation.zone,
parentDelegate, this, f), ZoneUnaryCallback); | 4748 return dart.as(dart.dcall(implementation.function, implementation.zone, pa
rentDelegate, this, f), ZoneUnaryCallback); |
| 4749 } | 4749 } |
| 4750 registerBinaryCallback(f) { | 4750 registerBinaryCallback(f) { |
| 4751 let implementation = this[_registerBinaryCallback]; | 4751 let implementation = this[_registerBinaryCallback]; |
| 4752 dart.assert(implementation != null); | 4752 dart.assert(implementation != null); |
| 4753 let parentDelegate = _parentDelegate(implementation.zone); | 4753 let parentDelegate = _parentDelegate(implementation.zone); |
| 4754 return dart.as(dart.dinvokef(implementation.function, implementation.zone,
parentDelegate, this, f), ZoneBinaryCallback); | 4754 return dart.as(dart.dcall(implementation.function, implementation.zone, pa
rentDelegate, this, f), ZoneBinaryCallback); |
| 4755 } | 4755 } |
| 4756 errorCallback(error, stackTrace) { | 4756 errorCallback(error, stackTrace) { |
| 4757 let implementation = this[_errorCallback]; | 4757 let implementation = this[_errorCallback]; |
| 4758 dart.assert(implementation != null); | 4758 dart.assert(implementation != null); |
| 4759 let implementationZone = implementation.zone; | 4759 let implementationZone = implementation.zone; |
| 4760 if (core.identical(implementationZone, _ROOT_ZONE)) | 4760 if (core.identical(implementationZone, _ROOT_ZONE)) |
| 4761 return null; | 4761 return null; |
| 4762 let parentDelegate = _parentDelegate(dart.as(implementationZone, _Zone)); | 4762 let parentDelegate = _parentDelegate(dart.as(implementationZone, _Zone)); |
| 4763 return dart.as(dart.dinvokef(implementation.function, implementationZone,
parentDelegate, this, error, stackTrace), AsyncError); | 4763 return dart.as(dart.dcall(implementation.function, implementationZone, par
entDelegate, this, error, stackTrace), AsyncError); |
| 4764 } | 4764 } |
| 4765 scheduleMicrotask(f) { | 4765 scheduleMicrotask(f) { |
| 4766 let implementation = this[_scheduleMicrotask]; | 4766 let implementation = this[_scheduleMicrotask]; |
| 4767 dart.assert(implementation != null); | 4767 dart.assert(implementation != null); |
| 4768 let parentDelegate = _parentDelegate(implementation.zone); | 4768 let parentDelegate = _parentDelegate(implementation.zone); |
| 4769 return dart.dinvokef(implementation.function, implementation.zone, parentD
elegate, this, f); | 4769 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, f); |
| 4770 } | 4770 } |
| 4771 createTimer(duration, f) { | 4771 createTimer(duration, f) { |
| 4772 let implementation = this[_createTimer]; | 4772 let implementation = this[_createTimer]; |
| 4773 dart.assert(implementation != null); | 4773 dart.assert(implementation != null); |
| 4774 let parentDelegate = _parentDelegate(implementation.zone); | 4774 let parentDelegate = _parentDelegate(implementation.zone); |
| 4775 return dart.as(dart.dinvokef(implementation.function, implementation.zone,
parentDelegate, this, duration, f), Timer); | 4775 return dart.as(dart.dcall(implementation.function, implementation.zone, pa
rentDelegate, this, duration, f), Timer); |
| 4776 } | 4776 } |
| 4777 createPeriodicTimer(duration, f) { | 4777 createPeriodicTimer(duration, f) { |
| 4778 let implementation = this[_createPeriodicTimer]; | 4778 let implementation = this[_createPeriodicTimer]; |
| 4779 dart.assert(implementation != null); | 4779 dart.assert(implementation != null); |
| 4780 let parentDelegate = _parentDelegate(implementation.zone); | 4780 let parentDelegate = _parentDelegate(implementation.zone); |
| 4781 return dart.as(dart.dinvokef(implementation.function, implementation.zone,
parentDelegate, this, duration, f), Timer); | 4781 return dart.as(dart.dcall(implementation.function, implementation.zone, pa
rentDelegate, this, duration, f), Timer); |
| 4782 } | 4782 } |
| 4783 print(line) { | 4783 print(line) { |
| 4784 let implementation = this[_print]; | 4784 let implementation = this[_print]; |
| 4785 dart.assert(implementation != null); | 4785 dart.assert(implementation != null); |
| 4786 let parentDelegate = _parentDelegate(implementation.zone); | 4786 let parentDelegate = _parentDelegate(implementation.zone); |
| 4787 return dart.dinvokef(implementation.function, implementation.zone, parentD
elegate, this, line); | 4787 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); |
| 4788 } | 4788 } |
| 4789 } | 4789 } |
| 4790 // Function _rootHandleUncaughtError: (Zone, ZoneDelegate, Zone, dynamic, Stac
kTrace) → void | 4790 // Function _rootHandleUncaughtError: (Zone, ZoneDelegate, Zone, dynamic, Stac
kTrace) → void |
| 4791 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { | 4791 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { |
| 4792 _schedulePriorityAsyncCallback(() => { | 4792 _schedulePriorityAsyncCallback(() => { |
| 4793 throw new _UncaughtAsyncError(error, stackTrace); | 4793 throw new _UncaughtAsyncError(error, stackTrace); |
| 4794 }); | 4794 }); |
| 4795 } | 4795 } |
| 4796 // Function _rootRun: (Zone, ZoneDelegate, Zone, () → dynamic) → dynamic | 4796 // Function _rootRun: (Zone, ZoneDelegate, Zone, () → dynamic) → dynamic |
| 4797 function _rootRun(self, parent, zone, f) { | 4797 function _rootRun(self, parent, zone, f) { |
| 4798 if (dart.equals(Zone[_current], zone)) | 4798 if (dart.equals(Zone[_current], zone)) |
| 4799 return f(); | 4799 return f(); |
| 4800 let old = Zone[_enter](zone); | 4800 let old = Zone[_enter](zone); |
| 4801 try { | 4801 try { |
| 4802 return f(); | 4802 return f(); |
| 4803 } finally { | 4803 } finally { |
| 4804 Zone[_leave](old); | 4804 Zone[_leave](old); |
| 4805 } | 4805 } |
| 4806 } | 4806 } |
| 4807 // Function _rootRunUnary: (Zone, ZoneDelegate, Zone, (dynamic) → dynamic, dyn
amic) → dynamic | 4807 // Function _rootRunUnary: (Zone, ZoneDelegate, Zone, (dynamic) → dynamic, dyn
amic) → dynamic |
| 4808 function _rootRunUnary(self, parent, zone, f, arg) { | 4808 function _rootRunUnary(self, parent, zone, f, arg) { |
| 4809 if (dart.equals(Zone[_current], zone)) | 4809 if (dart.equals(Zone[_current], zone)) |
| 4810 return dart.dinvokef(f, arg); | 4810 return dart.dcall(f, arg); |
| 4811 let old = Zone[_enter](zone); | 4811 let old = Zone[_enter](zone); |
| 4812 try { | 4812 try { |
| 4813 return dart.dinvokef(f, arg); | 4813 return dart.dcall(f, arg); |
| 4814 } finally { | 4814 } finally { |
| 4815 Zone[_leave](old); | 4815 Zone[_leave](old); |
| 4816 } | 4816 } |
| 4817 } | 4817 } |
| 4818 // Function _rootRunBinary: (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dy
namic, dynamic, dynamic) → dynamic | 4818 // Function _rootRunBinary: (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dy
namic, dynamic, dynamic) → dynamic |
| 4819 function _rootRunBinary(self, parent, zone, f, arg1, arg2) { | 4819 function _rootRunBinary(self, parent, zone, f, arg1, arg2) { |
| 4820 if (dart.equals(Zone[_current], zone)) | 4820 if (dart.equals(Zone[_current], zone)) |
| 4821 return dart.dinvokef(f, arg1, arg2); | 4821 return dart.dcall(f, arg1, arg2); |
| 4822 let old = Zone[_enter](zone); | 4822 let old = Zone[_enter](zone); |
| 4823 try { | 4823 try { |
| 4824 return dart.dinvokef(f, arg1, arg2); | 4824 return dart.dcall(f, arg1, arg2); |
| 4825 } finally { | 4825 } finally { |
| 4826 Zone[_leave](old); | 4826 Zone[_leave](old); |
| 4827 } | 4827 } |
| 4828 } | 4828 } |
| 4829 // Function _rootRegisterCallback: (Zone, ZoneDelegate, Zone, () → dynamic) →
ZoneCallback | 4829 // Function _rootRegisterCallback: (Zone, ZoneDelegate, Zone, () → dynamic) →
ZoneCallback |
| 4830 function _rootRegisterCallback(self, parent, zone, f) { | 4830 function _rootRegisterCallback(self, parent, zone, f) { |
| 4831 return f; | 4831 return f; |
| 4832 } | 4832 } |
| 4833 // Function _rootRegisterUnaryCallback: (Zone, ZoneDelegate, Zone, (dynamic) →
dynamic) → ZoneUnaryCallback | 4833 // Function _rootRegisterUnaryCallback: (Zone, ZoneDelegate, Zone, (dynamic) →
dynamic) → ZoneUnaryCallback |
| 4834 function _rootRegisterUnaryCallback(self, parent, zone, f) { | 4834 function _rootRegisterUnaryCallback(self, parent, zone, f) { |
| (...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5001 return _rootRun(null, null, this, f); | 5001 return _rootRun(null, null, this, f); |
| 5002 } catch (e) { | 5002 } catch (e) { |
| 5003 let s = dart.stackTrace(e); | 5003 let s = dart.stackTrace(e); |
| 5004 return this.handleUncaughtError(e, s); | 5004 return this.handleUncaughtError(e, s); |
| 5005 } | 5005 } |
| 5006 | 5006 |
| 5007 } | 5007 } |
| 5008 runUnaryGuarded(f, arg) { | 5008 runUnaryGuarded(f, arg) { |
| 5009 try { | 5009 try { |
| 5010 if (core.identical(_ROOT_ZONE, Zone[_current])) { | 5010 if (core.identical(_ROOT_ZONE, Zone[_current])) { |
| 5011 return dart.dinvokef(f, arg); | 5011 return dart.dcall(f, arg); |
| 5012 } | 5012 } |
| 5013 return _rootRunUnary(null, null, this, f, arg); | 5013 return _rootRunUnary(null, null, this, f, arg); |
| 5014 } catch (e) { | 5014 } catch (e) { |
| 5015 let s = dart.stackTrace(e); | 5015 let s = dart.stackTrace(e); |
| 5016 return this.handleUncaughtError(e, s); | 5016 return this.handleUncaughtError(e, s); |
| 5017 } | 5017 } |
| 5018 | 5018 |
| 5019 } | 5019 } |
| 5020 runBinaryGuarded(f, arg1, arg2) { | 5020 runBinaryGuarded(f, arg1, arg2) { |
| 5021 try { | 5021 try { |
| 5022 if (core.identical(_ROOT_ZONE, Zone[_current])) { | 5022 if (core.identical(_ROOT_ZONE, Zone[_current])) { |
| 5023 return dart.dinvokef(f, arg1, arg2); | 5023 return dart.dcall(f, arg1, arg2); |
| 5024 } | 5024 } |
| 5025 return _rootRunBinary(null, null, this, f, arg1, arg2); | 5025 return _rootRunBinary(null, null, this, f, arg1, arg2); |
| 5026 } catch (e) { | 5026 } catch (e) { |
| 5027 let s = dart.stackTrace(e); | 5027 let s = dart.stackTrace(e); |
| 5028 return this.handleUncaughtError(e, s); | 5028 return this.handleUncaughtError(e, s); |
| 5029 } | 5029 } |
| 5030 | 5030 |
| 5031 } | 5031 } |
| 5032 bindCallback(f, opts) { | 5032 bindCallback(f, opts) { |
| 5033 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; | 5033 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true; |
| (...skipping 30 matching lines...) Expand all Loading... |
| 5064 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 5064 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
| 5065 return _rootFork(null, null, this, specification, zoneValues); | 5065 return _rootFork(null, null, this, specification, zoneValues); |
| 5066 } | 5066 } |
| 5067 run(f) { | 5067 run(f) { |
| 5068 if (core.identical(Zone[_current], _ROOT_ZONE)) | 5068 if (core.identical(Zone[_current], _ROOT_ZONE)) |
| 5069 return f(); | 5069 return f(); |
| 5070 return _rootRun(null, null, this, f); | 5070 return _rootRun(null, null, this, f); |
| 5071 } | 5071 } |
| 5072 runUnary(f, arg) { | 5072 runUnary(f, arg) { |
| 5073 if (core.identical(Zone[_current], _ROOT_ZONE)) | 5073 if (core.identical(Zone[_current], _ROOT_ZONE)) |
| 5074 return dart.dinvokef(f, arg); | 5074 return dart.dcall(f, arg); |
| 5075 return _rootRunUnary(null, null, this, f, arg); | 5075 return _rootRunUnary(null, null, this, f, arg); |
| 5076 } | 5076 } |
| 5077 runBinary(f, arg1, arg2) { | 5077 runBinary(f, arg1, arg2) { |
| 5078 if (core.identical(Zone[_current], _ROOT_ZONE)) | 5078 if (core.identical(Zone[_current], _ROOT_ZONE)) |
| 5079 return dart.dinvokef(f, arg1, arg2); | 5079 return dart.dcall(f, arg1, arg2); |
| 5080 return _rootRunBinary(null, null, this, f, arg1, arg2); | 5080 return _rootRunBinary(null, null, this, f, arg1, arg2); |
| 5081 } | 5081 } |
| 5082 registerCallback(f) { | 5082 registerCallback(f) { |
| 5083 return f; | 5083 return f; |
| 5084 } | 5084 } |
| 5085 registerUnaryCallback(f) { | 5085 registerUnaryCallback(f) { |
| 5086 return f; | 5086 return f; |
| 5087 } | 5087 } |
| 5088 registerBinaryCallback(f) { | 5088 registerBinaryCallback(f) { |
| 5089 return f; | 5089 return f; |
| (...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5196 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5196 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5197 exports.CreateTimerHandler = CreateTimerHandler; | 5197 exports.CreateTimerHandler = CreateTimerHandler; |
| 5198 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5198 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5199 exports.PrintHandler = PrintHandler; | 5199 exports.PrintHandler = PrintHandler; |
| 5200 exports.ForkHandler = ForkHandler; | 5200 exports.ForkHandler = ForkHandler; |
| 5201 exports.ZoneSpecification = ZoneSpecification; | 5201 exports.ZoneSpecification = ZoneSpecification; |
| 5202 exports.ZoneDelegate = ZoneDelegate; | 5202 exports.ZoneDelegate = ZoneDelegate; |
| 5203 exports.Zone = Zone; | 5203 exports.Zone = Zone; |
| 5204 exports.runZoned = runZoned; | 5204 exports.runZoned = runZoned; |
| 5205 })(async || (async = {})); | 5205 })(async || (async = {})); |
| OLD | NEW |