Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(588)

Side by Side Diff: lib/runtime/dart/async.js

Issue 1074923003: rename dart_runtime.js helpers (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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 = {}));
OLDNEW
« no previous file with comments | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698