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

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

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

Powered by Google App Engine
This is Rietveld 408576698