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

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

Issue 1152583002: Add constructors to signatures (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 7 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
OLDNEW
1 var async = dart.defineLibrary(async, {}); 1 var async = dart.defineLibrary(async, {});
2 var core = dart.import(core); 2 var core = dart.import(core);
3 var _internal = dart.import(_internal); 3 var _internal = dart.import(_internal);
4 var _js_helper = dart.lazyImport(_js_helper); 4 var _js_helper = dart.lazyImport(_js_helper);
5 var _isolate_helper = dart.lazyImport(_isolate_helper); 5 var _isolate_helper = dart.lazyImport(_isolate_helper);
6 var collection = dart.import(collection); 6 var collection = dart.import(collection);
7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) {
8 'use strict'; 8 'use strict';
9 function _invokeErrorHandler(errorHandler, error, stackTrace) { 9 function _invokeErrorHandler(errorHandler, error, stackTrace) {
10 if (dart.is(errorHandler, ZoneBinaryCallback)) { 10 if (dart.is(errorHandler, ZoneBinaryCallback)) {
(...skipping 14 matching lines...) Expand all
25 class AsyncError extends core.Object { 25 class AsyncError extends core.Object {
26 AsyncError(error, stackTrace) { 26 AsyncError(error, stackTrace) {
27 this.error = error; 27 this.error = error;
28 this.stackTrace = stackTrace; 28 this.stackTrace = stackTrace;
29 } 29 }
30 toString() { 30 toString() {
31 return dart.toString(this.error); 31 return dart.toString(this.error);
32 } 32 }
33 } 33 }
34 AsyncError[dart.implements] = () => [core.Error]; 34 AsyncError[dart.implements] = () => [core.Error];
35 dart.setSignature(AsyncError, {
36 constructors: () => ({AsyncError: [AsyncError, [core.Object, core.StackTrace ]]})
37 });
35 class _UncaughtAsyncError extends AsyncError { 38 class _UncaughtAsyncError extends AsyncError {
36 _UncaughtAsyncError(error, stackTrace) { 39 _UncaughtAsyncError(error, stackTrace) {
37 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac kTrace)); 40 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac kTrace));
38 } 41 }
39 static _getBestStackTrace(error, stackTrace) { 42 static _getBestStackTrace(error, stackTrace) {
40 if (stackTrace != null) 43 if (stackTrace != null)
41 return stackTrace; 44 return stackTrace;
42 if (dart.is(error, core.Error)) { 45 if (dart.is(error, core.Error)) {
43 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); 46 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace);
44 } 47 }
45 return null; 48 return null;
46 } 49 }
47 toString() { 50 toString() {
48 let result = `Uncaught Error: ${this.error}`; 51 let result = `Uncaught Error: ${this.error}`;
49 if (this.stackTrace != null) { 52 if (this.stackTrace != null) {
50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; 53 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`;
51 } 54 }
52 return result; 55 return result;
53 } 56 }
54 } 57 }
55 dart.setSignature(_UncaughtAsyncError, { 58 dart.setSignature(_UncaughtAsyncError, {
59 constructors: () => ({_UncaughtAsyncError: [_UncaughtAsyncError, [core.Objec t, core.StackTrace]]}),
56 statics: () => ({_getBestStackTrace: [core.StackTrace, [core.Object, core.St ackTrace]]}), 60 statics: () => ({_getBestStackTrace: [core.StackTrace, [core.Object, core.St ackTrace]]}),
57 names: ['_getBestStackTrace'] 61 names: ['_getBestStackTrace']
58 }); 62 });
59 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(core.Obj ect, [dart.bottom])); 63 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(core.Obj ect, [dart.bottom]));
60 let _add = Symbol('_add'); 64 let _add = Symbol('_add');
61 let _closeUnchecked = Symbol('_closeUnchecked'); 65 let _closeUnchecked = Symbol('_closeUnchecked');
62 let _addError = Symbol('_addError'); 66 let _addError = Symbol('_addError');
63 let _completeError = Symbol('_completeError'); 67 let _completeError = Symbol('_completeError');
64 let _complete = Symbol('_complete'); 68 let _complete = Symbol('_complete');
65 let _sink = Symbol('_sink'); 69 let _sink = Symbol('_sink');
(...skipping 646 matching lines...) Expand 10 before | Expand all | Expand 10 after
712 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType (dart.void, []))); 716 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType (dart.void, [])));
713 }), onCancel); 717 }), onCancel);
714 return controller.stream; 718 return controller.stream;
715 } 719 }
716 } 720 }
717 dart.defineNamedConstructor(Stream, 'fromFuture'); 721 dart.defineNamedConstructor(Stream, 'fromFuture');
718 dart.defineNamedConstructor(Stream, 'fromIterable'); 722 dart.defineNamedConstructor(Stream, 'fromIterable');
719 dart.defineNamedConstructor(Stream, 'periodic'); 723 dart.defineNamedConstructor(Stream, 'periodic');
720 dart.defineNamedConstructor(Stream, 'eventTransformed'); 724 dart.defineNamedConstructor(Stream, 'eventTransformed');
721 dart.setSignature(Stream, { 725 dart.setSignature(Stream, {
726 constructors: () => ({
727 Stream: [Stream$(T), []],
728 fromFuture: [Stream$(T), [Future$(T)]],
729 fromIterable: [Stream$(T), [core.Iterable$(T)]],
730 periodic: [Stream$(T), [core.Duration], [dart.functionType(T, [core.int] )]],
731 eventTransformed: [Stream$(T), [Stream$(), dart.functionType(EventSink, [EventSink$(T)])]]
732 }),
722 methods: () => ({ 733 methods: () => ({
723 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void , [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri ption$(T)])}], 734 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void , [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri ption$(T)])}],
724 where: [Stream$(T), [dart.functionType(core.bool, [T])]], 735 where: [Stream$(T), [dart.functionType(core.bool, [T])]],
725 map: [Stream$(), [dart.functionType(core.Object, [T])]], 736 map: [Stream$(), [dart.functionType(core.Object, [T])]],
726 asyncMap: [Stream$(), [dart.functionType(core.Object, [T])]], 737 asyncMap: [Stream$(), [dart.functionType(core.Object, [T])]],
727 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]], 738 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]],
728 handleError: [Stream$(T), [core.Function], {es: dart.functionType(core.b ool, [dart.bottom])}], 739 handleError: [Stream$(T), [core.Function], {es: dart.functionType(core.b ool, [dart.bottom])}],
729 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]], 740 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]],
730 pipe: [Future, [StreamConsumer$(T)]], 741 pipe: [Future, [StreamConsumer$(T)]],
731 transform: [Stream$(), [StreamTransformer$(T, core.Object)]], 742 transform: [Stream$(), [StreamTransformer$(T, core.Object)]],
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after
807 ['=='](other) { 818 ['=='](other) {
808 if (core.identical(this, other)) 819 if (core.identical(this, other))
809 return true; 820 return true;
810 if (!dart.is(other, _ControllerStream$())) 821 if (!dart.is(other, _ControllerStream$()))
811 return false; 822 return false;
812 let otherStream = dart.as(other, _ControllerStream$()); 823 let otherStream = dart.as(other, _ControllerStream$());
813 return core.identical(otherStream[_controller], this[_controller]); 824 return core.identical(otherStream[_controller], this[_controller]);
814 } 825 }
815 } 826 }
816 dart.setSignature(_ControllerStream, { 827 dart.setSignature(_ControllerStream, {
828 constructors: () => ({_ControllerStream: [_ControllerStream$(T), [_StreamC ontrollerLifecycle$(T)]]}),
817 methods: () => ({ 829 methods: () => ({
818 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], 830 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]],
819 '==': [core.bool, [core.Object]] 831 '==': [core.bool, [core.Object]]
820 }) 832 })
821 }); 833 });
822 return _ControllerStream; 834 return _ControllerStream;
823 }); 835 });
824 let _ControllerStream = _ControllerStream$(); 836 let _ControllerStream = _ControllerStream$();
825 let _BroadcastStream$ = dart.generic(function(T) { 837 let _BroadcastStream$ = dart.generic(function(T) {
826 class _BroadcastStream extends _ControllerStream$(T) { 838 class _BroadcastStream extends _ControllerStream$(T) {
827 _BroadcastStream(controller) { 839 _BroadcastStream(controller) {
828 super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$( T))); 840 super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$( T)));
829 } 841 }
830 get isBroadcast() { 842 get isBroadcast() {
831 return true; 843 return true;
832 } 844 }
833 } 845 }
846 dart.setSignature(_BroadcastStream, {
847 constructors: () => ({_BroadcastStream: [_BroadcastStream$(T), [_StreamCon trollerLifecycle]]})
848 });
834 return _BroadcastStream; 849 return _BroadcastStream;
835 }); 850 });
836 let _BroadcastStream = _BroadcastStream$(); 851 let _BroadcastStream = _BroadcastStream$();
837 let _next = Symbol('_next'); 852 let _next = Symbol('_next');
838 let _previous = Symbol('_previous'); 853 let _previous = Symbol('_previous');
839 class _BroadcastSubscriptionLink extends core.Object { 854 class _BroadcastSubscriptionLink extends core.Object {
840 _BroadcastSubscriptionLink() { 855 _BroadcastSubscriptionLink() {
841 this[_next] = null; 856 this[_next] = null;
842 this[_previous] = null; 857 this[_previous] = null;
843 } 858 }
(...skipping 325 matching lines...) Expand 10 before | Expand all | Expand 10 after
1169 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt reamSubscription$()._STATE_IN_CALLBACK); 1184 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingSt reamSubscription$()._STATE_IN_CALLBACK);
1170 wasInputPaused = isInputPaused; 1185 wasInputPaused = isInputPaused;
1171 } 1186 }
1172 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) { 1187 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) {
1173 this[_pending].schedule(this); 1188 this[_pending].schedule(this);
1174 } 1189 }
1175 } 1190 }
1176 } 1191 }
1177 _BufferingStreamSubscription[dart.implements] = () => [StreamSubscription$(T ), _EventSink$(T), _EventDispatch$(T)]; 1192 _BufferingStreamSubscription[dart.implements] = () => [StreamSubscription$(T ), _EventSink$(T), _EventDispatch$(T)];
1178 dart.setSignature(_BufferingStreamSubscription, { 1193 dart.setSignature(_BufferingStreamSubscription, {
1194 constructors: () => ({_BufferingStreamSubscription: [_BufferingStreamSubsc ription$(T), [dart.functionType(dart.void, [T]), core.Function, dart.functionTyp e(dart.void, []), core.bool]]}),
1179 methods: () => ({ 1195 methods: () => ({
1180 [_setPendingEvents]: [dart.void, [_PendingEvents]], 1196 [_setPendingEvents]: [dart.void, [_PendingEvents]],
1181 [_extractPending]: [_PendingEvents, []], 1197 [_extractPending]: [_PendingEvents, []],
1182 onData: [dart.void, [dart.functionType(dart.void, [T])]], 1198 onData: [dart.void, [dart.functionType(dart.void, [T])]],
1183 onError: [dart.void, [core.Function]], 1199 onError: [dart.void, [core.Function]],
1184 onDone: [dart.void, [dart.functionType(dart.void, [])]], 1200 onDone: [dart.void, [dart.functionType(dart.void, [])]],
1185 pause: [dart.void, [], [Future]], 1201 pause: [dart.void, [], [Future]],
1186 resume: [dart.void, []], 1202 resume: [dart.void, []],
1187 cancel: [Future, []], 1203 cancel: [Future, []],
1188 asFuture: [Future, [], [core.Object]], 1204 asFuture: [Future, [], [core.Object]],
(...skipping 29 matching lines...) Expand all
1218 [_onCancel]() { 1234 [_onCancel]() {
1219 return this[_controller][_recordCancel](this); 1235 return this[_controller][_recordCancel](this);
1220 } 1236 }
1221 [_onPause]() { 1237 [_onPause]() {
1222 this[_controller][_recordPause](this); 1238 this[_controller][_recordPause](this);
1223 } 1239 }
1224 [_onResume]() { 1240 [_onResume]() {
1225 this[_controller][_recordResume](this); 1241 this[_controller][_recordResume](this);
1226 } 1242 }
1227 } 1243 }
1244 dart.setSignature(_ControllerSubscription, {
1245 constructors: () => ({_ControllerSubscription: [_ControllerSubscription$(T ), [_StreamControllerLifecycle$(T), dart.functionType(dart.void, [T]), core.Func tion, dart.functionType(dart.void, []), core.bool]]})
1246 });
1228 return _ControllerSubscription; 1247 return _ControllerSubscription;
1229 }); 1248 });
1230 let _ControllerSubscription = _ControllerSubscription$(); 1249 let _ControllerSubscription = _ControllerSubscription$();
1231 let _eventState = Symbol('_eventState'); 1250 let _eventState = Symbol('_eventState');
1232 let _expectsEvent = Symbol('_expectsEvent'); 1251 let _expectsEvent = Symbol('_expectsEvent');
1233 let _toggleEventId = Symbol('_toggleEventId'); 1252 let _toggleEventId = Symbol('_toggleEventId');
1234 let _isFiring = Symbol('_isFiring'); 1253 let _isFiring = Symbol('_isFiring');
1235 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); 1254 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring');
1236 let _removeAfterFiring = Symbol('_removeAfterFiring'); 1255 let _removeAfterFiring = Symbol('_removeAfterFiring');
1237 let _BroadcastSubscription$ = dart.generic(function(T) { 1256 let _BroadcastSubscription$ = dart.generic(function(T) {
(...skipping 22 matching lines...) Expand all
1260 this[_eventState] = dart.notNull(this[_eventState]) | dart.notNull(_Broa dcastSubscription$()._STATE_REMOVE_AFTER_FIRING); 1279 this[_eventState] = dart.notNull(this[_eventState]) | dart.notNull(_Broa dcastSubscription$()._STATE_REMOVE_AFTER_FIRING);
1261 } 1280 }
1262 get [_removeAfterFiring]() { 1281 get [_removeAfterFiring]() {
1263 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri ption$()._STATE_REMOVE_AFTER_FIRING)) != 0; 1282 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri ption$()._STATE_REMOVE_AFTER_FIRING)) != 0;
1264 } 1283 }
1265 [_onPause]() {} 1284 [_onPause]() {}
1266 [_onResume]() {} 1285 [_onResume]() {}
1267 } 1286 }
1268 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ; 1287 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ;
1269 dart.setSignature(_BroadcastSubscription, { 1288 dart.setSignature(_BroadcastSubscription, {
1289 constructors: () => ({_BroadcastSubscription: [_BroadcastSubscription$(T), [_StreamControllerLifecycle, dart.functionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}),
1270 methods: () => ({ 1290 methods: () => ({
1271 [_expectsEvent]: [core.bool, [core.int]], 1291 [_expectsEvent]: [core.bool, [core.int]],
1272 [_toggleEventId]: [dart.void, []], 1292 [_toggleEventId]: [dart.void, []],
1273 [_setRemoveAfterFiring]: [dart.void, []] 1293 [_setRemoveAfterFiring]: [dart.void, []]
1274 }) 1294 })
1275 }); 1295 });
1276 return _BroadcastSubscription; 1296 return _BroadcastSubscription;
1277 }); 1297 });
1278 let _BroadcastSubscription = _BroadcastSubscription$(); 1298 let _BroadcastSubscription = _BroadcastSubscription$();
1279 _BroadcastSubscription._STATE_EVENT_ID = 1; 1299 _BroadcastSubscription._STATE_EVENT_ID = 1;
(...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after
1494 [_callOnCancel]() { 1514 [_callOnCancel]() {
1495 dart.assert(this[_isEmpty]); 1515 dart.assert(this[_isEmpty]);
1496 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) { 1516 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) {
1497 this[_doneFuture][_asyncComplete](null); 1517 this[_doneFuture][_asyncComplete](null);
1498 } 1518 }
1499 _runGuarded(this[_onCancel]); 1519 _runGuarded(this[_onCancel]);
1500 } 1520 }
1501 } 1521 }
1502 _BroadcastStreamController[dart.implements] = () => [StreamController$(T), _ StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _Even tDispatch$(T)]; 1522 _BroadcastStreamController[dart.implements] = () => [StreamController$(T), _ StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _Even tDispatch$(T)];
1503 dart.setSignature(_BroadcastStreamController, { 1523 dart.setSignature(_BroadcastStreamController, {
1524 constructors: () => ({_BroadcastStreamController: [_BroadcastStreamControl ler$(T), [_NotificationHandler, _NotificationHandler]]}),
1504 methods: () => ({ 1525 methods: () => ({
1505 [_ensureDoneFuture]: [_Future, []], 1526 [_ensureDoneFuture]: [_Future, []],
1506 [_addListener]: [dart.void, [_BroadcastSubscription$(T)]], 1527 [_addListener]: [dart.void, [_BroadcastSubscription$(T)]],
1507 [_removeListener]: [dart.void, [_BroadcastSubscription$(T)]], 1528 [_removeListener]: [dart.void, [_BroadcastSubscription$(T)]],
1508 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T] ), core.Function, dart.functionType(dart.void, []), core.bool]], 1529 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T] ), core.Function, dart.functionType(dart.void, []), core.bool]],
1509 [_recordCancel]: [Future, [StreamSubscription$(T)]], 1530 [_recordCancel]: [Future, [StreamSubscription$(T)]],
1510 [_recordPause]: [dart.void, [StreamSubscription$(T)]], 1531 [_recordPause]: [dart.void, [StreamSubscription$(T)]],
1511 [_recordResume]: [dart.void, [StreamSubscription$(T)]], 1532 [_recordResume]: [dart.void, [StreamSubscription$(T)]],
1512 [_addEventError]: [core.Error, []], 1533 [_addEventError]: [core.Error, []],
1513 add: [dart.void, [T]], 1534 add: [dart.void, [T]],
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
1568 subscription[_close](); 1589 subscription[_close]();
1569 }, core.Object, [_BroadcastSubscription$(T)]), __CastType2)); 1590 }, core.Object, [_BroadcastSubscription$(T)]), __CastType2));
1570 } else { 1591 } else {
1571 dart.assert(this[_doneFuture] != null); 1592 dart.assert(this[_doneFuture] != null);
1572 dart.assert(this[_doneFuture][_mayComplete]); 1593 dart.assert(this[_doneFuture][_mayComplete]);
1573 this[_doneFuture][_asyncComplete](null); 1594 this[_doneFuture][_asyncComplete](null);
1574 } 1595 }
1575 } 1596 }
1576 } 1597 }
1577 dart.setSignature(_SyncBroadcastStreamController, { 1598 dart.setSignature(_SyncBroadcastStreamController, {
1599 constructors: () => ({_SyncBroadcastStreamController: [_SyncBroadcastStrea mController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void, [])]]}),
1578 methods: () => ({ 1600 methods: () => ({
1579 [_sendData]: [dart.void, [T]], 1601 [_sendData]: [dart.void, [T]],
1580 [_sendError]: [dart.void, [core.Object, core.StackTrace]], 1602 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
1581 [_sendDone]: [dart.void, []] 1603 [_sendDone]: [dart.void, []]
1582 }) 1604 })
1583 }); 1605 });
1584 return _SyncBroadcastStreamController; 1606 return _SyncBroadcastStreamController;
1585 }); 1607 });
1586 let _SyncBroadcastStreamController = _SyncBroadcastStreamController$(); 1608 let _SyncBroadcastStreamController = _SyncBroadcastStreamController$();
1587 let _AsyncBroadcastStreamController$ = dart.generic(function(T) { 1609 let _AsyncBroadcastStreamController$ = dart.generic(function(T) {
(...skipping 21 matching lines...) Expand all
1609 subscription[_addPending](dart.const(new _DelayedDone())); 1631 subscription[_addPending](dart.const(new _DelayedDone()));
1610 } 1632 }
1611 } else { 1633 } else {
1612 dart.assert(this[_doneFuture] != null); 1634 dart.assert(this[_doneFuture] != null);
1613 dart.assert(this[_doneFuture][_mayComplete]); 1635 dart.assert(this[_doneFuture][_mayComplete]);
1614 this[_doneFuture][_asyncComplete](null); 1636 this[_doneFuture][_asyncComplete](null);
1615 } 1637 }
1616 } 1638 }
1617 } 1639 }
1618 dart.setSignature(_AsyncBroadcastStreamController, { 1640 dart.setSignature(_AsyncBroadcastStreamController, {
1641 constructors: () => ({_AsyncBroadcastStreamController: [_AsyncBroadcastStr eamController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.voi d, [])]]}),
1619 methods: () => ({ 1642 methods: () => ({
1620 [_sendData]: [dart.void, [T]], 1643 [_sendData]: [dart.void, [T]],
1621 [_sendError]: [dart.void, [core.Object, core.StackTrace]], 1644 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
1622 [_sendDone]: [dart.void, []] 1645 [_sendDone]: [dart.void, []]
1623 }) 1646 })
1624 }); 1647 });
1625 return _AsyncBroadcastStreamController; 1648 return _AsyncBroadcastStreamController;
1626 }); 1649 });
1627 let _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$(); 1650 let _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$();
1628 let _addPendingEvent = Symbol('_addPendingEvent'); 1651 let _addPendingEvent = Symbol('_addPendingEvent');
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
1679 [_callOnCancel]() { 1702 [_callOnCancel]() {
1680 if (this[_hasPending]) { 1703 if (this[_hasPending]) {
1681 this[_pending].clear(); 1704 this[_pending].clear();
1682 this[_pending] = null; 1705 this[_pending] = null;
1683 } 1706 }
1684 super[_callOnCancel](); 1707 super[_callOnCancel]();
1685 } 1708 }
1686 } 1709 }
1687 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)]; 1710 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)];
1688 dart.setSignature(_AsBroadcastStreamController, { 1711 dart.setSignature(_AsBroadcastStreamController, {
1712 constructors: () => ({_AsBroadcastStreamController: [_AsBroadcastStreamCon troller$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void, []) ]]}),
1689 methods: () => ({ 1713 methods: () => ({
1690 [_addPendingEvent]: [dart.void, [_DelayedEvent]], 1714 [_addPendingEvent]: [dart.void, [_DelayedEvent]],
1691 add: [dart.void, [T]] 1715 add: [dart.void, [T]]
1692 }) 1716 })
1693 }); 1717 });
1694 return _AsBroadcastStreamController; 1718 return _AsBroadcastStreamController;
1695 }); 1719 });
1696 let _AsBroadcastStreamController = _AsBroadcastStreamController$(); 1720 let _AsBroadcastStreamController = _AsBroadcastStreamController$();
1697 let _pauseCount = Symbol('_pauseCount'); 1721 let _pauseCount = Symbol('_pauseCount');
1698 let _resume = Symbol('_resume'); 1722 let _resume = Symbol('_resume');
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
1760 DeferredLibrary(libraryName, opts) { 1784 DeferredLibrary(libraryName, opts) {
1761 let uri = opts && 'uri' in opts ? opts.uri : null; 1785 let uri = opts && 'uri' in opts ? opts.uri : null;
1762 this.libraryName = libraryName; 1786 this.libraryName = libraryName;
1763 this.uri = uri; 1787 this.uri = uri;
1764 } 1788 }
1765 load() { 1789 load() {
1766 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar t" deferred as lib` syntax.'; 1790 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar t" deferred as lib` syntax.';
1767 } 1791 }
1768 } 1792 }
1769 dart.setSignature(DeferredLibrary, { 1793 dart.setSignature(DeferredLibrary, {
1794 constructors: () => ({DeferredLibrary: [DeferredLibrary, [core.String], {r: core.String}]}),
1770 methods: () => ({load: [Future$(core.Null), []]}) 1795 methods: () => ({load: [Future$(core.Null), []]})
1771 }); 1796 });
1772 let _s = Symbol('_s'); 1797 let _s = Symbol('_s');
1773 class DeferredLoadException extends core.Object { 1798 class DeferredLoadException extends core.Object {
1774 DeferredLoadException(s) { 1799 DeferredLoadException(s) {
1775 this[_s] = s; 1800 this[_s] = s;
1776 } 1801 }
1777 toString() { 1802 toString() {
1778 return `DeferredLoadException: '${this[_s]}'`; 1803 return `DeferredLoadException: '${this[_s]}'`;
1779 } 1804 }
1780 } 1805 }
1781 DeferredLoadException[dart.implements] = () => [core.Exception]; 1806 DeferredLoadException[dart.implements] = () => [core.Exception];
1807 dart.setSignature(DeferredLoadException, {
1808 constructors: () => ({DeferredLoadException: [DeferredLoadException, [core.S tring]]})
1809 });
1782 let _completeWithValue = Symbol('_completeWithValue'); 1810 let _completeWithValue = Symbol('_completeWithValue');
1783 let Future$ = dart.generic(function(T) { 1811 let Future$ = dart.generic(function(T) {
1784 class Future extends core.Object { 1812 class Future extends core.Object {
1785 Future(computation) { 1813 Future(computation) {
1786 let result = new (_Future$(T))(); 1814 let result = new (_Future$(T))();
1787 Timer.run(dart.fn(() => { 1815 Timer.run(dart.fn(() => {
1788 try { 1816 try {
1789 result[_complete](computation()); 1817 result[_complete](computation());
1790 } catch (e) { 1818 } catch (e) {
1791 let s = dart.stackTrace(e); 1819 let s = dart.stackTrace(e);
(...skipping 143 matching lines...) Expand 10 before | Expand all | Expand 10 after
1935 dart.dcall(nextIteration, true); 1963 dart.dcall(nextIteration, true);
1936 return doneSignal; 1964 return doneSignal;
1937 } 1965 }
1938 } 1966 }
1939 dart.defineNamedConstructor(Future, 'microtask'); 1967 dart.defineNamedConstructor(Future, 'microtask');
1940 dart.defineNamedConstructor(Future, 'sync'); 1968 dart.defineNamedConstructor(Future, 'sync');
1941 dart.defineNamedConstructor(Future, 'value'); 1969 dart.defineNamedConstructor(Future, 'value');
1942 dart.defineNamedConstructor(Future, 'error'); 1970 dart.defineNamedConstructor(Future, 'error');
1943 dart.defineNamedConstructor(Future, 'delayed'); 1971 dart.defineNamedConstructor(Future, 'delayed');
1944 dart.setSignature(Future, { 1972 dart.setSignature(Future, {
1973 constructors: () => ({
1974 Future: [Future$(T), [dart.functionType(core.Object, [])]],
1975 microtask: [Future$(T), [dart.functionType(core.Object, [])]],
1976 sync: [Future$(T), [dart.functionType(core.Object, [])]],
1977 value: [Future$(T), [], [core.Object]],
1978 error: [Future$(T), [core.Object], [core.StackTrace]],
1979 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]]
1980 }),
1945 statics: () => ({ 1981 statics: () => ({
1946 wait: [Future$(core.List), [core.Iterable$(Future$())], {agerErro: core. bool, leanU: dart.functionType(dart.void, [dart.bottom])}], 1982 wait: [Future$(core.List), [core.Iterable$(Future$())], {agerErro: core. bool, leanU: dart.functionType(dart.void, [dart.bottom])}],
1947 forEach: [Future$(), [core.Iterable, dart.functionType(core.Object, [dar t.bottom])]], 1983 forEach: [Future$(), [core.Iterable, dart.functionType(core.Object, [dar t.bottom])]],
1948 doWhile: [Future$(), [dart.functionType(core.Object, [])]] 1984 doWhile: [Future$(), [dart.functionType(core.Object, [])]]
1949 }), 1985 }),
1950 names: ['wait', 'forEach', 'doWhile'] 1986 names: ['wait', 'forEach', 'doWhile']
1951 }); 1987 });
1952 return Future; 1988 return Future;
1953 }); 1989 });
1954 let Future = Future$(); 1990 let Future = Future$();
(...skipping 12 matching lines...) Expand all
1967 toString() { 2003 toString() {
1968 let result = "TimeoutException"; 2004 let result = "TimeoutException";
1969 if (this.duration != null) 2005 if (this.duration != null)
1970 result = `TimeoutException after ${this.duration}`; 2006 result = `TimeoutException after ${this.duration}`;
1971 if (this.message != null) 2007 if (this.message != null)
1972 result = `${result}: ${this.message}`; 2008 result = `${result}: ${this.message}`;
1973 return result; 2009 return result;
1974 } 2010 }
1975 } 2011 }
1976 TimeoutException[dart.implements] = () => [core.Exception]; 2012 TimeoutException[dart.implements] = () => [core.Exception];
2013 dart.setSignature(TimeoutException, {
2014 constructors: () => ({TimeoutException: [TimeoutException, [core.String], [c ore.Duration]]})
2015 });
1977 let Completer$ = dart.generic(function(T) { 2016 let Completer$ = dart.generic(function(T) {
1978 class Completer extends core.Object { 2017 class Completer extends core.Object {
1979 Completer() { 2018 Completer() {
1980 return new (_AsyncCompleter$(T))(); 2019 return new (_AsyncCompleter$(T))();
1981 } 2020 }
1982 sync() { 2021 sync() {
1983 return new (_SyncCompleter$(T))(); 2022 return new (_SyncCompleter$(T))();
1984 } 2023 }
1985 } 2024 }
1986 dart.defineNamedConstructor(Completer, 'sync'); 2025 dart.defineNamedConstructor(Completer, 'sync');
2026 dart.setSignature(Completer, {
2027 constructors: () => ({
2028 Completer: [Completer$(T), []],
2029 sync: [Completer$(T), []]
2030 })
2031 });
1987 return Completer; 2032 return Completer;
1988 }); 2033 });
1989 let Completer = Completer$(); 2034 let Completer = Completer$();
1990 function _completeWithErrorCallback(result, error, stackTrace) { 2035 function _completeWithErrorCallback(result, error, stackTrace) {
1991 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core .StackTrace)); 2036 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core .StackTrace));
1992 if (replacement != null) { 2037 if (replacement != null) {
1993 error = _nonNullError(replacement.error); 2038 error = _nonNullError(replacement.error);
1994 stackTrace = replacement.stackTrace; 2039 stackTrace = replacement.stackTrace;
1995 } 2040 }
1996 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); 2041 result[_completeError](error, dart.as(stackTrace, core.StackTrace));
(...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after
2149 } 2194 }
2150 get [_whenCompleteAction]() { 2195 get [_whenCompleteAction]() {
2151 dart.assert(this.handlesComplete); 2196 dart.assert(this.handlesComplete);
2152 return dart.as(this.callback, _FutureAction); 2197 return dart.as(this.callback, _FutureAction);
2153 } 2198 }
2154 } 2199 }
2155 dart.defineNamedConstructor(_FutureListener, 'then'); 2200 dart.defineNamedConstructor(_FutureListener, 'then');
2156 dart.defineNamedConstructor(_FutureListener, 'catchError'); 2201 dart.defineNamedConstructor(_FutureListener, 'catchError');
2157 dart.defineNamedConstructor(_FutureListener, 'whenComplete'); 2202 dart.defineNamedConstructor(_FutureListener, 'whenComplete');
2158 dart.defineNamedConstructor(_FutureListener, 'chain'); 2203 dart.defineNamedConstructor(_FutureListener, 'chain');
2204 dart.setSignature(_FutureListener, {
2205 constructors: () => ({
2206 then: [_FutureListener, [_Future, _FutureOnValue, core.Function]],
2207 catchError: [_FutureListener, [_Future, core.Function, _FutureErrorTest]],
2208 whenComplete: [_FutureListener, [_Future, _FutureAction]],
2209 chain: [_FutureListener, [_Future]]
2210 })
2211 });
2159 _FutureListener.MASK_VALUE = 1; 2212 _FutureListener.MASK_VALUE = 1;
2160 _FutureListener.MASK_ERROR = 2; 2213 _FutureListener.MASK_ERROR = 2;
2161 _FutureListener.MASK_TEST_ERROR = 4; 2214 _FutureListener.MASK_TEST_ERROR = 4;
2162 _FutureListener.MASK_WHENCOMPLETE = 8; 2215 _FutureListener.MASK_WHENCOMPLETE = 8;
2163 _FutureListener.STATE_CHAIN = 0; 2216 _FutureListener.STATE_CHAIN = 0;
2164 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE; 2217 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE;
2165 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureListener.MASK_ERROR); 2218 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureListener.MASK_ERROR);
2166 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR; 2219 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR;
2167 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO R) | dart.notNull(_FutureListener.MASK_TEST_ERROR); 2220 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO R) | dart.notNull(_FutureListener.MASK_TEST_ERROR);
2168 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE; 2221 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE;
(...skipping 424 matching lines...) Expand 10 before | Expand all | Expand 10 after
2593 result[_completeError](e, dart.as(s, core.StackTrace)); 2646 result[_completeError](e, dart.as(s, core.StackTrace));
2594 } 2647 }
2595 })}); 2648 })});
2596 return result; 2649 return result;
2597 } 2650 }
2598 } 2651 }
2599 _Future[dart.implements] = () => [Future$(T)]; 2652 _Future[dart.implements] = () => [Future$(T)];
2600 dart.defineNamedConstructor(_Future, 'immediate'); 2653 dart.defineNamedConstructor(_Future, 'immediate');
2601 dart.defineNamedConstructor(_Future, 'immediateError'); 2654 dart.defineNamedConstructor(_Future, 'immediateError');
2602 dart.setSignature(_Future, { 2655 dart.setSignature(_Future, {
2656 constructors: () => ({
2657 _Future: [_Future$(T), []],
2658 immediate: [_Future$(T), [core.Object]],
2659 immediateError: [_Future$(T), [core.Object], [core.StackTrace]]
2660 }),
2603 methods: () => ({ 2661 methods: () => ({
2604 then: [Future, [dart.functionType(core.Object, [T])], {nErro: core.Funct ion}], 2662 then: [Future, [dart.functionType(core.Object, [T])], {nErro: core.Funct ion}],
2605 catchError: [Future, [core.Function], {es: dart.functionType(core.bool, [dart.bottom])}], 2663 catchError: [Future, [core.Function], {es: dart.functionType(core.bool, [dart.bottom])}],
2606 whenComplete: [Future$(T), [dart.functionType(core.Object, [])]], 2664 whenComplete: [Future$(T), [dart.functionType(core.Object, [])]],
2607 asStream: [Stream$(T), []], 2665 asStream: [Stream$(T), []],
2608 [_markPendingCompletion]: [dart.void, []], 2666 [_markPendingCompletion]: [dart.void, []],
2609 [_setValue]: [dart.void, [T]], 2667 [_setValue]: [dart.void, [T]],
2610 [_setErrorObject]: [dart.void, [AsyncError]], 2668 [_setErrorObject]: [dart.void, [AsyncError]],
2611 [_setError]: [dart.void, [core.Object, core.StackTrace]], 2669 [_setError]: [dart.void, [core.Object, core.StackTrace]],
2612 [_addListener]: [dart.void, [_FutureListener]], 2670 [_addListener]: [dart.void, [_FutureListener]],
(...skipping 27 matching lines...) Expand all
2640 let __CastType6 = __CastType6$(); 2698 let __CastType6 = __CastType6$();
2641 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo l, [dart.bottom])); 2699 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo l, [dart.bottom]));
2642 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(core.O bject, [dart.bottom])); 2700 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(core.O bject, [dart.bottom]));
2643 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da rt.void, [])); 2701 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da rt.void, []));
2644 class _AsyncCallbackEntry extends core.Object { 2702 class _AsyncCallbackEntry extends core.Object {
2645 _AsyncCallbackEntry(callback) { 2703 _AsyncCallbackEntry(callback) {
2646 this.callback = callback; 2704 this.callback = callback;
2647 this.next = null; 2705 this.next = null;
2648 } 2706 }
2649 } 2707 }
2708 dart.setSignature(_AsyncCallbackEntry, {
2709 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall back]]})
2710 });
2650 exports._nextCallback = null; 2711 exports._nextCallback = null;
2651 exports._lastCallback = null; 2712 exports._lastCallback = null;
2652 exports._lastPriorityCallback = null; 2713 exports._lastPriorityCallback = null;
2653 exports._isInCallbackLoop = false; 2714 exports._isInCallbackLoop = false;
2654 function _asyncRunCallbackLoop() { 2715 function _asyncRunCallbackLoop() {
2655 while (exports._nextCallback != null) { 2716 while (exports._nextCallback != null) {
2656 exports._lastPriorityCallback = null; 2717 exports._lastPriorityCallback = null;
2657 let entry = exports._nextCallback; 2718 let entry = exports._nextCallback;
2658 exports._nextCallback = entry.next; 2719 exports._nextCallback = entry.next;
2659 if (exports._nextCallback == null) 2720 if (exports._nextCallback == null)
(...skipping 157 matching lines...) Expand 10 before | Expand all | Expand 10 after
2817 listen(onData, opts) { 2878 listen(onData, opts) {
2818 dart.as(onData, dart.functionType(dart.void, [T])); 2879 dart.as(onData, dart.functionType(dart.void, [T]));
2819 let onError = opts && 'onError' in opts ? opts.onError : null; 2880 let onError = opts && 'onError' in opts ? opts.onError : null;
2820 let onDone = opts && 'onDone' in opts ? opts.onDone : null; 2881 let onDone = opts && 'onDone' in opts ? opts.onDone : null;
2821 dart.as(onDone, dart.functionType(dart.void, [])); 2882 dart.as(onDone, dart.functionType(dart.void, []));
2822 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 2883 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
2823 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c ancelOnError: cancelOnError}); 2884 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c ancelOnError: cancelOnError});
2824 } 2885 }
2825 } 2886 }
2826 dart.setSignature(StreamView, { 2887 dart.setSignature(StreamView, {
2888 constructors: () => ({StreamView: [StreamView$(T), [Stream$(T)]]}),
2827 methods: () => ({ 2889 methods: () => ({
2828 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void , [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri ption$(T)])}], 2890 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void , [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri ption$(T)])}],
2829 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}] 2891 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}]
2830 }) 2892 })
2831 }); 2893 });
2832 return StreamView; 2894 return StreamView;
2833 }); 2895 });
2834 let StreamView = StreamView$(); 2896 let StreamView = StreamView$();
2835 let StreamConsumer$ = dart.generic(function(S) { 2897 let StreamConsumer$ = dart.generic(function(S) {
2836 class StreamConsumer extends core.Object {} 2898 class StreamConsumer extends core.Object {}
2837 return StreamConsumer; 2899 return StreamConsumer;
2838 }); 2900 });
2839 let StreamConsumer = StreamConsumer$(); 2901 let StreamConsumer = StreamConsumer$();
2840 let StreamSink$ = dart.generic(function(S) { 2902 let StreamSink$ = dart.generic(function(S) {
2841 class StreamSink extends core.Object {} 2903 class StreamSink extends core.Object {}
2842 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)]; 2904 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)];
2843 return StreamSink; 2905 return StreamSink;
2844 }); 2906 });
2845 let StreamSink = StreamSink$(); 2907 let StreamSink = StreamSink$();
2846 let StreamTransformer$ = dart.generic(function(S, T) { 2908 let StreamTransformer$ = dart.generic(function(S, T) {
2847 class StreamTransformer extends core.Object { 2909 class StreamTransformer extends core.Object {
2848 StreamTransformer(transformer) { 2910 StreamTransformer(transformer) {
2849 return new _StreamSubscriptionTransformer(transformer); 2911 return new _StreamSubscriptionTransformer(transformer);
2850 } 2912 }
2851 fromHandlers(opts) { 2913 fromHandlers(opts) {
2852 return new _StreamHandlerTransformer(opts); 2914 return new _StreamHandlerTransformer(opts);
2853 } 2915 }
2854 } 2916 }
2855 dart.defineNamedConstructor(StreamTransformer, 'fromHandlers'); 2917 dart.defineNamedConstructor(StreamTransformer, 'fromHandlers');
2918 dart.setSignature(StreamTransformer, {
2919 constructors: () => ({
2920 StreamTransformer: [StreamTransformer$(S, T), [dart.functionType(StreamS ubscription$(T), [Stream$(S), core.bool])]],
2921 fromHandlers: [StreamTransformer$(S, T), [], {andleDat: dart.functionTyp e(dart.void, [S, EventSink$(T)]), andleErro: dart.functionType(dart.void, [core. Object, core.StackTrace, EventSink$(T)]), andleDon: dart.functionType(dart.void, [EventSink$(T)])}]
2922 })
2923 });
2856 return StreamTransformer; 2924 return StreamTransformer;
2857 }); 2925 });
2858 let StreamTransformer = StreamTransformer$(); 2926 let StreamTransformer = StreamTransformer$();
2859 let StreamIterator$ = dart.generic(function(T) { 2927 let StreamIterator$ = dart.generic(function(T) {
2860 class StreamIterator extends core.Object { 2928 class StreamIterator extends core.Object {
2861 StreamIterator(stream) { 2929 StreamIterator(stream) {
2862 return new (_StreamIteratorImpl$(T))(stream); 2930 return new (_StreamIteratorImpl$(T))(stream);
2863 } 2931 }
2864 } 2932 }
2933 dart.setSignature(StreamIterator, {
2934 constructors: () => ({StreamIterator: [StreamIterator$(T), [Stream$(T)]]})
2935 });
2865 return StreamIterator; 2936 return StreamIterator;
2866 }); 2937 });
2867 let StreamIterator = StreamIterator$(); 2938 let StreamIterator = StreamIterator$();
2868 let _ControllerEventSinkWrapper$ = dart.generic(function(T) { 2939 let _ControllerEventSinkWrapper$ = dart.generic(function(T) {
2869 class _ControllerEventSinkWrapper extends core.Object { 2940 class _ControllerEventSinkWrapper extends core.Object {
2870 _ControllerEventSinkWrapper(sink) { 2941 _ControllerEventSinkWrapper(sink) {
2871 this[_sink] = sink; 2942 this[_sink] = sink;
2872 } 2943 }
2873 add(data) { 2944 add(data) {
2874 dart.as(data, T); 2945 dart.as(data, T);
2875 this[_sink].add(data); 2946 this[_sink].add(data);
2876 } 2947 }
2877 addError(error, stackTrace) { 2948 addError(error, stackTrace) {
2878 if (stackTrace === void 0) 2949 if (stackTrace === void 0)
2879 stackTrace = null; 2950 stackTrace = null;
2880 this[_sink].addError(error, stackTrace); 2951 this[_sink].addError(error, stackTrace);
2881 } 2952 }
2882 close() { 2953 close() {
2883 this[_sink].close(); 2954 this[_sink].close();
2884 } 2955 }
2885 } 2956 }
2886 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; 2957 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)];
2887 dart.setSignature(_ControllerEventSinkWrapper, { 2958 dart.setSignature(_ControllerEventSinkWrapper, {
2959 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr apper$(T), [EventSink]]}),
2888 methods: () => ({ 2960 methods: () => ({
2889 add: [dart.void, [T]], 2961 add: [dart.void, [T]],
2890 addError: [dart.void, [core.Object], [core.StackTrace]], 2962 addError: [dart.void, [core.Object], [core.StackTrace]],
2891 close: [dart.void, []] 2963 close: [dart.void, []]
2892 }) 2964 })
2893 }); 2965 });
2894 return _ControllerEventSinkWrapper; 2966 return _ControllerEventSinkWrapper;
2895 }); 2967 });
2896 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); 2968 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$();
2897 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v oid, [StreamSubscription])); 2969 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v oid, [StreamSubscription]));
(...skipping 15 matching lines...) Expand all
2913 } 2985 }
2914 broadcast(opts) { 2986 broadcast(opts) {
2915 let onListen = opts && 'onListen' in opts ? opts.onListen : null; 2987 let onListen = opts && 'onListen' in opts ? opts.onListen : null;
2916 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; 2988 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
2917 let sync = opts && 'sync' in opts ? opts.sync : false; 2989 let sync = opts && 'sync' in opts ? opts.sync : false;
2918 return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCance l) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel); 2990 return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCance l) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel);
2919 } 2991 }
2920 } 2992 }
2921 StreamController[dart.implements] = () => [StreamSink$(T)]; 2993 StreamController[dart.implements] = () => [StreamSink$(T)];
2922 dart.defineNamedConstructor(StreamController, 'broadcast'); 2994 dart.defineNamedConstructor(StreamController, 'broadcast');
2995 dart.setSignature(StreamController, {
2996 constructors: () => ({
2997 StreamController: [StreamController$(T), [], {nListe: dart.functionType( dart.void, []), nPaus: dart.functionType(dart.void, []), nResum: dart.functionTy pe(dart.void, []), nCance: dart.functionType(core.Object, []), yn: core.bool}],
2998 broadcast: [StreamController$(T), [], {nListe: dart.functionType(dart.vo id, []), nCance: dart.functionType(dart.void, []), yn: core.bool}]
2999 })
3000 });
2923 return StreamController; 3001 return StreamController;
2924 }); 3002 });
2925 let StreamController = StreamController$(); 3003 let StreamController = StreamController$();
2926 let _StreamControllerLifecycle$ = dart.generic(function(T) { 3004 let _StreamControllerLifecycle$ = dart.generic(function(T) {
2927 class _StreamControllerLifecycle extends core.Object { 3005 class _StreamControllerLifecycle extends core.Object {
2928 [_recordPause](subscription) { 3006 [_recordPause](subscription) {
2929 dart.as(subscription, StreamSubscription$(T)); 3007 dart.as(subscription, StreamSubscription$(T));
2930 } 3008 }
2931 [_recordResume](subscription) { 3009 [_recordResume](subscription) {
2932 dart.as(subscription, StreamSubscription$(T)); 3010 dart.as(subscription, StreamSubscription$(T));
(...skipping 237 matching lines...) Expand 10 before | Expand all | Expand 10 after
3170 dart.as(subscription, StreamSubscription$(T)); 3248 dart.as(subscription, StreamSubscription$(T));
3171 if (this[_isAddingStream]) { 3249 if (this[_isAddingStream]) {
3172 let addState = dart.as(this[_varData], _StreamControllerAddStreamState ); 3250 let addState = dart.as(this[_varData], _StreamControllerAddStreamState );
3173 addState.resume(); 3251 addState.resume();
3174 } 3252 }
3175 _runGuarded(this[_onResume]); 3253 _runGuarded(this[_onResume]);
3176 } 3254 }
3177 } 3255 }
3178 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; 3256 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)];
3179 dart.setSignature(_StreamController, { 3257 dart.setSignature(_StreamController, {
3258 constructors: () => ({_StreamController: [_StreamController$(T), []]}),
3180 methods: () => ({ 3259 methods: () => ({
3181 [_ensurePendingEvents]: [_StreamImplEvents, []], 3260 [_ensurePendingEvents]: [_StreamImplEvents, []],
3182 [_badEventState]: [core.Error, []], 3261 [_badEventState]: [core.Error, []],
3183 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}], 3262 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}],
3184 [_ensureDoneFuture]: [Future, []], 3263 [_ensureDoneFuture]: [Future, []],
3185 add: [dart.void, [T]], 3264 add: [dart.void, [T]],
3186 addError: [dart.void, [core.Object], [core.StackTrace]], 3265 addError: [dart.void, [core.Object], [core.StackTrace]],
3187 close: [Future, []], 3266 close: [Future, []],
3188 [_closeUnchecked]: [dart.void, []], 3267 [_closeUnchecked]: [dart.void, []],
3189 [_add]: [dart.void, [T]], 3268 [_add]: [dart.void, [T]],
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after
3255 let _AsyncStreamController$ = dart.generic(function(T) { 3334 let _AsyncStreamController$ = dart.generic(function(T) {
3256 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) { 3335 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) {
3257 _AsyncStreamController(onListen, onPause, onResume, onCancel) { 3336 _AsyncStreamController(onListen, onPause, onResume, onCancel) {
3258 this[_onListen] = onListen; 3337 this[_onListen] = onListen;
3259 this[_onPause] = onPause; 3338 this[_onPause] = onPause;
3260 this[_onResume] = onResume; 3339 this[_onResume] = onResume;
3261 this[_onCancel] = onCancel; 3340 this[_onCancel] = onCancel;
3262 super._StreamController(); 3341 super._StreamController();
3263 } 3342 }
3264 } 3343 }
3344 dart.setSignature(_AsyncStreamController, {
3345 constructors: () => ({_AsyncStreamController: [_AsyncStreamController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void, []), dart.funct ionType(dart.void, []), dart.functionType(core.Object, [])]]})
3346 });
3265 return _AsyncStreamController; 3347 return _AsyncStreamController;
3266 }); 3348 });
3267 let _AsyncStreamController = _AsyncStreamController$(); 3349 let _AsyncStreamController = _AsyncStreamController$();
3268 let _SyncStreamController$ = dart.generic(function(T) { 3350 let _SyncStreamController$ = dart.generic(function(T) {
3269 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS treamControllerDispatch$(T)) { 3351 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS treamControllerDispatch$(T)) {
3270 _SyncStreamController(onListen, onPause, onResume, onCancel) { 3352 _SyncStreamController(onListen, onPause, onResume, onCancel) {
3271 this[_onListen] = onListen; 3353 this[_onListen] = onListen;
3272 this[_onPause] = onPause; 3354 this[_onPause] = onPause;
3273 this[_onResume] = onResume; 3355 this[_onResume] = onResume;
3274 this[_onCancel] = onCancel; 3356 this[_onCancel] = onCancel;
3275 super._StreamController(); 3357 super._StreamController();
3276 } 3358 }
3277 } 3359 }
3360 dart.setSignature(_SyncStreamController, {
3361 constructors: () => ({_SyncStreamController: [_SyncStreamController$(T), [ dart.functionType(dart.void, []), dart.functionType(dart.void, []), dart.functio nType(dart.void, []), dart.functionType(core.Object, [])]]})
3362 });
3278 return _SyncStreamController; 3363 return _SyncStreamController;
3279 }); 3364 });
3280 let _SyncStreamController = _SyncStreamController$(); 3365 let _SyncStreamController = _SyncStreamController$();
3281 class _NoCallbacks extends core.Object { 3366 class _NoCallbacks extends core.Object {
3282 get [_onListen]() { 3367 get [_onListen]() {
3283 return null; 3368 return null;
3284 } 3369 }
3285 get [_onPause]() { 3370 get [_onPause]() {
3286 return null; 3371 return null;
3287 } 3372 }
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
3332 dart.as(source, Stream$(T)); 3417 dart.as(source, Stream$(T));
3333 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true; 3418 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
3334 return this[_target].addStream(source, {cancelOnError: cancelOnError}); 3419 return this[_target].addStream(source, {cancelOnError: cancelOnError});
3335 } 3420 }
3336 get done() { 3421 get done() {
3337 return this[_target].done; 3422 return this[_target].done;
3338 } 3423 }
3339 } 3424 }
3340 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)]; 3425 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)];
3341 dart.setSignature(_StreamSinkWrapper, { 3426 dart.setSignature(_StreamSinkWrapper, {
3427 constructors: () => ({_StreamSinkWrapper: [_StreamSinkWrapper$(T), [Stream Controller]]}),
3342 methods: () => ({ 3428 methods: () => ({
3343 add: [dart.void, [T]], 3429 add: [dart.void, [T]],
3344 addError: [dart.void, [core.Object], [core.StackTrace]], 3430 addError: [dart.void, [core.Object], [core.StackTrace]],
3345 close: [Future, []], 3431 close: [Future, []],
3346 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}] 3432 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}]
3347 }) 3433 })
3348 }); 3434 });
3349 return _StreamSinkWrapper; 3435 return _StreamSinkWrapper;
3350 }); 3436 });
3351 let _StreamSinkWrapper = _StreamSinkWrapper$(); 3437 let _StreamSinkWrapper = _StreamSinkWrapper$();
(...skipping 23 matching lines...) Expand all
3375 } 3461 }
3376 return cancel.whenComplete(dart.fn((() => { 3462 return cancel.whenComplete(dart.fn((() => {
3377 this.addStreamFuture[_asyncComplete](null); 3463 this.addStreamFuture[_asyncComplete](null);
3378 }).bind(this))); 3464 }).bind(this)));
3379 } 3465 }
3380 complete() { 3466 complete() {
3381 this.addStreamFuture[_asyncComplete](null); 3467 this.addStreamFuture[_asyncComplete](null);
3382 } 3468 }
3383 } 3469 }
3384 dart.setSignature(_AddStreamState, { 3470 dart.setSignature(_AddStreamState, {
3471 constructors: () => ({_AddStreamState: [_AddStreamState$(T), [_EventSink$( T), Stream, core.bool]]}),
3385 methods: () => ({ 3472 methods: () => ({
3386 pause: [dart.void, []], 3473 pause: [dart.void, []],
3387 resume: [dart.void, []], 3474 resume: [dart.void, []],
3388 cancel: [Future, []], 3475 cancel: [Future, []],
3389 complete: [dart.void, []] 3476 complete: [dart.void, []]
3390 }), 3477 }),
3391 statics: () => ({makeErrorHandler: [core.Object, [_EventSink]]}), 3478 statics: () => ({makeErrorHandler: [core.Object, [_EventSink]]}),
3392 names: ['makeErrorHandler'] 3479 names: ['makeErrorHandler']
3393 }); 3480 });
3394 return _AddStreamState; 3481 return _AddStreamState;
3395 }); 3482 });
3396 let _AddStreamState = _AddStreamState$(); 3483 let _AddStreamState = _AddStreamState$();
3397 let _StreamControllerAddStreamState$ = dart.generic(function(T) { 3484 let _StreamControllerAddStreamState$ = dart.generic(function(T) {
3398 class _StreamControllerAddStreamState extends _AddStreamState$(T) { 3485 class _StreamControllerAddStreamState extends _AddStreamState$(T) {
3399 _StreamControllerAddStreamState(controller, varData, source, cancelOnError ) { 3486 _StreamControllerAddStreamState(controller, varData, source, cancelOnError ) {
3400 this.varData = varData; 3487 this.varData = varData;
3401 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance lOnError); 3488 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance lOnError);
3402 if (controller.isPaused) { 3489 if (controller.isPaused) {
3403 this.addSubscription.pause(); 3490 this.addSubscription.pause();
3404 } 3491 }
3405 } 3492 }
3406 } 3493 }
3494 dart.setSignature(_StreamControllerAddStreamState, {
3495 constructors: () => ({_StreamControllerAddStreamState: [_StreamControllerA ddStreamState$(T), [_StreamController, core.Object, Stream, core.bool]]})
3496 });
3407 return _StreamControllerAddStreamState; 3497 return _StreamControllerAddStreamState;
3408 }); 3498 });
3409 let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(); 3499 let _StreamControllerAddStreamState = _StreamControllerAddStreamState$();
3410 let _EventSink$ = dart.generic(function(T) { 3500 let _EventSink$ = dart.generic(function(T) {
3411 class _EventSink extends core.Object {} 3501 class _EventSink extends core.Object {}
3412 return _EventSink; 3502 return _EventSink;
3413 }); 3503 });
3414 let _EventSink = _EventSink$(); 3504 let _EventSink = _EventSink$();
3415 let _EventDispatch$ = dart.generic(function(T) { 3505 let _EventDispatch$ = dart.generic(function(T) {
3416 class _EventDispatch extends core.Object {} 3506 class _EventDispatch extends core.Object {}
(...skipping 24 matching lines...) Expand all
3441 throw new core.StateError("Stream has already been listened to."); 3531 throw new core.StateError("Stream has already been listened to.");
3442 this[_isUsed] = true; 3532 this[_isUsed] = true;
3443 return dart.as((() => { 3533 return dart.as((() => {
3444 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc elOnError); 3534 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc elOnError);
3445 _[_setPendingEvents](this[_pending]()); 3535 _[_setPendingEvents](this[_pending]());
3446 return _; 3536 return _;
3447 }).bind(this)(), StreamSubscription$(T)); 3537 }).bind(this)(), StreamSubscription$(T));
3448 } 3538 }
3449 } 3539 }
3450 dart.setSignature(_GeneratedStreamImpl, { 3540 dart.setSignature(_GeneratedStreamImpl, {
3541 constructors: () => ({_GeneratedStreamImpl: [_GeneratedStreamImpl$(T), [_E ventGenerator]]}),
3451 methods: () => ({[_createSubscription]: [StreamSubscription$(T), [dart.fun ctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core .bool]]}) 3542 methods: () => ({[_createSubscription]: [StreamSubscription$(T), [dart.fun ctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core .bool]]})
3452 }); 3543 });
3453 return _GeneratedStreamImpl; 3544 return _GeneratedStreamImpl;
3454 }); 3545 });
3455 let _GeneratedStreamImpl = _GeneratedStreamImpl$(); 3546 let _GeneratedStreamImpl = _GeneratedStreamImpl$();
3456 let _eventScheduled = Symbol('_eventScheduled'); 3547 let _eventScheduled = Symbol('_eventScheduled');
3457 class _PendingEvents extends core.Object { 3548 class _PendingEvents extends core.Object {
3458 _PendingEvents() { 3549 _PendingEvents() {
3459 this[_state] = _PendingEvents._STATE_UNSCHEDULED; 3550 this[_state] = _PendingEvents._STATE_UNSCHEDULED;
3460 } 3551 }
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after
3524 dispatch[_sendDone](); 3615 dispatch[_sendDone]();
3525 } 3616 }
3526 } 3617 }
3527 clear() { 3618 clear() {
3528 if (this.isScheduled) 3619 if (this.isScheduled)
3529 this.cancelSchedule(); 3620 this.cancelSchedule();
3530 this[_iterator] = null; 3621 this[_iterator] = null;
3531 } 3622 }
3532 } 3623 }
3533 dart.setSignature(_IterablePendingEvents, { 3624 dart.setSignature(_IterablePendingEvents, {
3625 constructors: () => ({_IterablePendingEvents: [_IterablePendingEvents$(T), [core.Iterable$(T)]]}),
3534 methods: () => ({ 3626 methods: () => ({
3535 handleNext: [dart.void, [_EventDispatch]], 3627 handleNext: [dart.void, [_EventDispatch]],
3536 clear: [dart.void, []] 3628 clear: [dart.void, []]
3537 }) 3629 })
3538 }); 3630 });
3539 return _IterablePendingEvents; 3631 return _IterablePendingEvents;
3540 }); 3632 });
3541 let _IterablePendingEvents = _IterablePendingEvents$(); 3633 let _IterablePendingEvents = _IterablePendingEvents$();
3542 let _DataHandler$ = dart.generic(function(T) { 3634 let _DataHandler$ = dart.generic(function(T) {
3543 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart .void, [T])); 3635 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart .void, [T]));
(...skipping 27 matching lines...) Expand all
3571 _DelayedData(value) { 3663 _DelayedData(value) {
3572 this.value = value; 3664 this.value = value;
3573 super._DelayedEvent(); 3665 super._DelayedEvent();
3574 } 3666 }
3575 perform(dispatch) { 3667 perform(dispatch) {
3576 dart.as(dispatch, _EventDispatch$(T)); 3668 dart.as(dispatch, _EventDispatch$(T));
3577 dispatch[_sendData](this.value); 3669 dispatch[_sendData](this.value);
3578 } 3670 }
3579 } 3671 }
3580 dart.setSignature(_DelayedData, { 3672 dart.setSignature(_DelayedData, {
3673 constructors: () => ({_DelayedData: [_DelayedData$(T), [T]]}),
3581 methods: () => ({perform: [dart.void, [_EventDispatch$(T)]]}) 3674 methods: () => ({perform: [dart.void, [_EventDispatch$(T)]]})
3582 }); 3675 });
3583 return _DelayedData; 3676 return _DelayedData;
3584 }); 3677 });
3585 let _DelayedData = _DelayedData$(); 3678 let _DelayedData = _DelayedData$();
3586 class _DelayedError extends _DelayedEvent { 3679 class _DelayedError extends _DelayedEvent {
3587 _DelayedError(error, stackTrace) { 3680 _DelayedError(error, stackTrace) {
3588 this.error = error; 3681 this.error = error;
3589 this.stackTrace = stackTrace; 3682 this.stackTrace = stackTrace;
3590 super._DelayedEvent(); 3683 super._DelayedEvent();
3591 } 3684 }
3592 perform(dispatch) { 3685 perform(dispatch) {
3593 dispatch[_sendError](this.error, this.stackTrace); 3686 dispatch[_sendError](this.error, this.stackTrace);
3594 } 3687 }
3595 } 3688 }
3596 dart.setSignature(_DelayedError, { 3689 dart.setSignature(_DelayedError, {
3690 constructors: () => ({_DelayedError: [_DelayedError, [core.Object, core.Stac kTrace]]}),
3597 methods: () => ({perform: [dart.void, [_EventDispatch]]}) 3691 methods: () => ({perform: [dart.void, [_EventDispatch]]})
3598 }); 3692 });
3599 class _DelayedDone extends core.Object { 3693 class _DelayedDone extends core.Object {
3600 _DelayedDone() { 3694 _DelayedDone() {
3601 } 3695 }
3602 perform(dispatch) { 3696 perform(dispatch) {
3603 dispatch[_sendDone](); 3697 dispatch[_sendDone]();
3604 } 3698 }
3605 get next() { 3699 get next() {
3606 return null; 3700 return null;
3607 } 3701 }
3608 set next(_) { 3702 set next(_) {
3609 throw new core.StateError("No events after a done."); 3703 throw new core.StateError("No events after a done.");
3610 } 3704 }
3611 } 3705 }
3612 _DelayedDone[dart.implements] = () => [_DelayedEvent]; 3706 _DelayedDone[dart.implements] = () => [_DelayedEvent];
3613 dart.setSignature(_DelayedDone, { 3707 dart.setSignature(_DelayedDone, {
3708 constructors: () => ({_DelayedDone: [_DelayedDone, []]}),
3614 methods: () => ({perform: [dart.void, [_EventDispatch]]}) 3709 methods: () => ({perform: [dart.void, [_EventDispatch]]})
3615 }); 3710 });
3616 _PendingEvents._STATE_UNSCHEDULED = 0; 3711 _PendingEvents._STATE_UNSCHEDULED = 0;
3617 _PendingEvents._STATE_SCHEDULED = 1; 3712 _PendingEvents._STATE_SCHEDULED = 1;
3618 _PendingEvents._STATE_CANCELED = 3; 3713 _PendingEvents._STATE_CANCELED = 3;
3619 class _StreamImplEvents extends _PendingEvents { 3714 class _StreamImplEvents extends _PendingEvents {
3620 _StreamImplEvents() { 3715 _StreamImplEvents() {
3621 this.firstPendingEvent = null; 3716 this.firstPendingEvent = null;
3622 this.lastPendingEvent = null; 3717 this.lastPendingEvent = null;
3623 super._PendingEvents(); 3718 super._PendingEvents();
(...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after
3746 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_DoneStreamSub scription$()._SCHEDULED); 3841 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_DoneStreamSub scription$()._SCHEDULED);
3747 if (this.isPaused) 3842 if (this.isPaused)
3748 return; 3843 return;
3749 this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubs cription$()._DONE_SENT); 3844 this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubs cription$()._DONE_SENT);
3750 if (this[_onDone] != null) 3845 if (this[_onDone] != null)
3751 this[_zone].runGuarded(this[_onDone]); 3846 this[_zone].runGuarded(this[_onDone]);
3752 } 3847 }
3753 } 3848 }
3754 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)]; 3849 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)];
3755 dart.setSignature(_DoneStreamSubscription, { 3850 dart.setSignature(_DoneStreamSubscription, {
3851 constructors: () => ({_DoneStreamSubscription: [_DoneStreamSubscription$(T ), [_DoneHandler]]}),
3756 methods: () => ({ 3852 methods: () => ({
3757 [_schedule]: [dart.void, []], 3853 [_schedule]: [dart.void, []],
3758 onData: [dart.void, [dart.functionType(dart.void, [T])]], 3854 onData: [dart.void, [dart.functionType(dart.void, [T])]],
3759 onError: [dart.void, [core.Function]], 3855 onError: [dart.void, [core.Function]],
3760 onDone: [dart.void, [dart.functionType(dart.void, [])]], 3856 onDone: [dart.void, [dart.functionType(dart.void, [])]],
3761 pause: [dart.void, [], [Future]], 3857 pause: [dart.void, [], [Future]],
3762 resume: [dart.void, []], 3858 resume: [dart.void, []],
3763 cancel: [Future, []], 3859 cancel: [Future, []],
3764 asFuture: [Future, [], [core.Object]], 3860 asFuture: [Future, [], [core.Object]],
3765 [_sendDone]: [dart.void, []] 3861 [_sendDone]: [dart.void, []]
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after
3843 return; 3939 return;
3844 this[_subscription].resume(); 3940 this[_subscription].resume();
3845 } 3941 }
3846 get [_isSubscriptionPaused]() { 3942 get [_isSubscriptionPaused]() {
3847 if (this[_subscription] == null) 3943 if (this[_subscription] == null)
3848 return false; 3944 return false;
3849 return this[_subscription].isPaused; 3945 return this[_subscription].isPaused;
3850 } 3946 }
3851 } 3947 }
3852 dart.setSignature(_AsBroadcastStream, { 3948 dart.setSignature(_AsBroadcastStream, {
3949 constructors: () => ({_AsBroadcastStream: [_AsBroadcastStream$(T), [Stream $(T), dart.functionType(dart.void, [StreamSubscription]), dart.functionType(dart .void, [StreamSubscription])]]}),
3853 methods: () => ({ 3950 methods: () => ({
3854 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}], 3951 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}],
3855 [_onCancel]: [dart.void, []], 3952 [_onCancel]: [dart.void, []],
3856 [_onListen]: [dart.void, []], 3953 [_onListen]: [dart.void, []],
3857 [_cancelSubscription]: [dart.void, []], 3954 [_cancelSubscription]: [dart.void, []],
3858 [_pauseSubscription]: [dart.void, [Future]], 3955 [_pauseSubscription]: [dart.void, [Future]],
3859 [_resumeSubscription]: [dart.void, []] 3956 [_resumeSubscription]: [dart.void, []]
3860 }) 3957 })
3861 }); 3958 });
3862 return _AsBroadcastStream; 3959 return _AsBroadcastStream;
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
3894 return this[_stream][_isSubscriptionPaused]; 3991 return this[_stream][_isSubscriptionPaused];
3895 } 3992 }
3896 asFuture(futureValue) { 3993 asFuture(futureValue) {
3897 if (futureValue === void 0) 3994 if (futureValue === void 0)
3898 futureValue = null; 3995 futureValue = null;
3899 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt ream source subscription."); 3996 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt ream source subscription.");
3900 } 3997 }
3901 } 3998 }
3902 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)]; 3999 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)];
3903 dart.setSignature(_BroadcastSubscriptionWrapper, { 4000 dart.setSignature(_BroadcastSubscriptionWrapper, {
4001 constructors: () => ({_BroadcastSubscriptionWrapper: [_BroadcastSubscripti onWrapper$(T), [_AsBroadcastStream]]}),
3904 methods: () => ({ 4002 methods: () => ({
3905 onData: [dart.void, [dart.functionType(dart.void, [T])]], 4003 onData: [dart.void, [dart.functionType(dart.void, [T])]],
3906 onError: [dart.void, [core.Function]], 4004 onError: [dart.void, [core.Function]],
3907 onDone: [dart.void, [dart.functionType(dart.void, [])]], 4005 onDone: [dart.void, [dart.functionType(dart.void, [])]],
3908 pause: [dart.void, [], [Future]], 4006 pause: [dart.void, [], [Future]],
3909 resume: [dart.void, []], 4007 resume: [dart.void, []],
3910 cancel: [Future, []], 4008 cancel: [Future, []],
3911 asFuture: [Future, [], [core.Object]] 4009 asFuture: [Future, [], [core.Object]]
3912 }) 4010 })
3913 }); 4011 });
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after
4019 hasNext[_complete](false); 4117 hasNext[_complete](false);
4020 return; 4118 return;
4021 } 4119 }
4022 this[_subscription].pause(); 4120 this[_subscription].pause();
4023 this[_futureOrPrefetch] = null; 4121 this[_futureOrPrefetch] = null;
4024 this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_DONE; 4122 this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_DONE;
4025 } 4123 }
4026 } 4124 }
4027 _StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)]; 4125 _StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)];
4028 dart.setSignature(_StreamIteratorImpl, { 4126 dart.setSignature(_StreamIteratorImpl, {
4127 constructors: () => ({_StreamIteratorImpl: [_StreamIteratorImpl$(T), [Stre am$(T)]]}),
4029 methods: () => ({ 4128 methods: () => ({
4030 moveNext: [Future$(core.bool), []], 4129 moveNext: [Future$(core.bool), []],
4031 [_clear]: [dart.void, []], 4130 [_clear]: [dart.void, []],
4032 cancel: [Future, []], 4131 cancel: [Future, []],
4033 [_onData]: [dart.void, [T]], 4132 [_onData]: [dart.void, [T]],
4034 [_onError]: [dart.void, [core.Object], [core.StackTrace]], 4133 [_onError]: [dart.void, [core.Object], [core.StackTrace]],
4035 [_onDone]: [dart.void, []] 4134 [_onDone]: [dart.void, []]
4036 }) 4135 })
4037 }); 4136 });
4038 return _StreamIteratorImpl; 4137 return _StreamIteratorImpl;
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
4134 [_handleError](error, stackTrace, sink) { 4233 [_handleError](error, stackTrace, sink) {
4135 dart.as(sink, _EventSink$(T)); 4234 dart.as(sink, _EventSink$(T));
4136 sink[_addError](error, stackTrace); 4235 sink[_addError](error, stackTrace);
4137 } 4236 }
4138 [_handleDone](sink) { 4237 [_handleDone](sink) {
4139 dart.as(sink, _EventSink$(T)); 4238 dart.as(sink, _EventSink$(T));
4140 sink[_close](); 4239 sink[_close]();
4141 } 4240 }
4142 } 4241 }
4143 dart.setSignature(_ForwardingStream, { 4242 dart.setSignature(_ForwardingStream, {
4243 constructors: () => ({_ForwardingStream: [_ForwardingStream$(S, T), [Strea m$(S)]]}),
4144 methods: () => ({ 4244 methods: () => ({
4145 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}], 4245 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}],
4146 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], 4246 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]],
4147 [_handleData]: [dart.void, [S, _EventSink$(T)]], 4247 [_handleData]: [dart.void, [S, _EventSink$(T)]],
4148 [_handleError]: [dart.void, [core.Object, core.StackTrace, _EventSink$(T )]], 4248 [_handleError]: [dart.void, [core.Object, core.StackTrace, _EventSink$(T )]],
4149 [_handleDone]: [dart.void, [_EventSink$(T)]] 4249 [_handleDone]: [dart.void, [_EventSink$(T)]]
4150 }) 4250 })
4151 }); 4251 });
4152 return _ForwardingStream; 4252 return _ForwardingStream;
4153 }); 4253 });
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
4194 this[_stream][_handleData](data, this); 4294 this[_stream][_handleData](data, this);
4195 } 4295 }
4196 [_handleError](error, stackTrace) { 4296 [_handleError](error, stackTrace) {
4197 this[_stream][_handleError](error, stackTrace, this); 4297 this[_stream][_handleError](error, stackTrace, this);
4198 } 4298 }
4199 [_handleDone]() { 4299 [_handleDone]() {
4200 this[_stream][_handleDone](this); 4300 this[_stream][_handleDone](this);
4201 } 4301 }
4202 } 4302 }
4203 dart.setSignature(_ForwardingStreamSubscription, { 4303 dart.setSignature(_ForwardingStreamSubscription, {
4304 constructors: () => ({_ForwardingStreamSubscription: [_ForwardingStreamSub scription$(S, T), [_ForwardingStream$(S, T), dart.functionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}),
4204 methods: () => ({ 4305 methods: () => ({
4205 [_add]: [dart.void, [T]], 4306 [_add]: [dart.void, [T]],
4206 [_handleData]: [dart.void, [S]], 4307 [_handleData]: [dart.void, [S]],
4207 [_handleError]: [dart.void, [core.Object, core.StackTrace]], 4308 [_handleError]: [dart.void, [core.Object, core.StackTrace]],
4208 [_handleDone]: [dart.void, []] 4309 [_handleDone]: [dart.void, []]
4209 }) 4310 })
4210 }); 4311 });
4211 return _ForwardingStreamSubscription; 4312 return _ForwardingStreamSubscription;
4212 }); 4313 });
4213 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); 4314 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$();
(...skipping 29 matching lines...) Expand all
4243 _addErrorWithReplacement(sink, e, s); 4344 _addErrorWithReplacement(sink, e, s);
4244 return; 4345 return;
4245 } 4346 }
4246 4347
4247 if (satisfies) { 4348 if (satisfies) {
4248 sink[_add](inputEvent); 4349 sink[_add](inputEvent);
4249 } 4350 }
4250 } 4351 }
4251 } 4352 }
4252 dart.setSignature(_WhereStream, { 4353 dart.setSignature(_WhereStream, {
4354 constructors: () => ({_WhereStream: [_WhereStream$(T), [Stream$(T), dart.f unctionType(core.bool, [T])]]}),
4253 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4355 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4254 }); 4356 });
4255 return _WhereStream; 4357 return _WhereStream;
4256 }); 4358 });
4257 let _WhereStream = _WhereStream$(); 4359 let _WhereStream = _WhereStream$();
4258 let _Transformation$ = dart.generic(function(S, T) { 4360 let _Transformation$ = dart.generic(function(S, T) {
4259 let _Transformation = dart.typedef('_Transformation', () => dart.functionTyp e(T, [S])); 4361 let _Transformation = dart.typedef('_Transformation', () => dart.functionTyp e(T, [S]));
4260 return _Transformation; 4362 return _Transformation;
4261 }); 4363 });
4262 let _Transformation = _Transformation$(); 4364 let _Transformation = _Transformation$();
(...skipping 13 matching lines...) Expand all
4276 } catch (e) { 4378 } catch (e) {
4277 let s = dart.stackTrace(e); 4379 let s = dart.stackTrace(e);
4278 _addErrorWithReplacement(sink, e, s); 4380 _addErrorWithReplacement(sink, e, s);
4279 return; 4381 return;
4280 } 4382 }
4281 4383
4282 sink[_add](outputEvent); 4384 sink[_add](outputEvent);
4283 } 4385 }
4284 } 4386 }
4285 dart.setSignature(_MapStream, { 4387 dart.setSignature(_MapStream, {
4388 constructors: () => ({_MapStream: [_MapStream$(S, T), [Stream$(S), dart.fu nctionType(T, [S])]]}),
4286 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]}) 4389 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]})
4287 }); 4390 });
4288 return _MapStream; 4391 return _MapStream;
4289 }); 4392 });
4290 let _MapStream = _MapStream$(); 4393 let _MapStream = _MapStream$();
4291 let _expand = Symbol('_expand'); 4394 let _expand = Symbol('_expand');
4292 let _ExpandStream$ = dart.generic(function(S, T) { 4395 let _ExpandStream$ = dart.generic(function(S, T) {
4293 class _ExpandStream extends _ForwardingStream$(S, T) { 4396 class _ExpandStream extends _ForwardingStream$(S, T) {
4294 _ExpandStream(source, expand) { 4397 _ExpandStream(source, expand) {
4295 this[_expand] = expand; 4398 this[_expand] = expand;
4296 super._ForwardingStream(source); 4399 super._ForwardingStream(source);
4297 } 4400 }
4298 [_handleData](inputEvent, sink) { 4401 [_handleData](inputEvent, sink) {
4299 dart.as(inputEvent, S); 4402 dart.as(inputEvent, S);
4300 dart.as(sink, _EventSink$(T)); 4403 dart.as(sink, _EventSink$(T));
4301 try { 4404 try {
4302 for (let value of this[_expand](inputEvent)) { 4405 for (let value of this[_expand](inputEvent)) {
4303 sink[_add](value); 4406 sink[_add](value);
4304 } 4407 }
4305 } catch (e) { 4408 } catch (e) {
4306 let s = dart.stackTrace(e); 4409 let s = dart.stackTrace(e);
4307 _addErrorWithReplacement(sink, e, s); 4410 _addErrorWithReplacement(sink, e, s);
4308 } 4411 }
4309 4412
4310 } 4413 }
4311 } 4414 }
4312 dart.setSignature(_ExpandStream, { 4415 dart.setSignature(_ExpandStream, {
4416 constructors: () => ({_ExpandStream: [_ExpandStream$(S, T), [Stream$(S), d art.functionType(core.Iterable$(T), [S])]]}),
4313 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]}) 4417 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]})
4314 }); 4418 });
4315 return _ExpandStream; 4419 return _ExpandStream;
4316 }); 4420 });
4317 let _ExpandStream = _ExpandStream$(); 4421 let _ExpandStream = _ExpandStream$();
4318 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool, [dart.bottom])); 4422 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool, [dart.bottom]));
4319 let _HandleErrorStream$ = dart.generic(function(T) { 4423 let _HandleErrorStream$ = dart.generic(function(T) {
4320 class _HandleErrorStream extends _ForwardingStream$(T, T) { 4424 class _HandleErrorStream extends _ForwardingStream$(T, T) {
4321 _HandleErrorStream(source, onError, test) { 4425 _HandleErrorStream(source, onError, test) {
4322 this[_transform] = onError; 4426 this[_transform] = onError;
(...skipping 25 matching lines...) Expand all
4348 } 4452 }
4349 return; 4453 return;
4350 } 4454 }
4351 4455
4352 } else { 4456 } else {
4353 sink[_addError](error, stackTrace); 4457 sink[_addError](error, stackTrace);
4354 } 4458 }
4355 } 4459 }
4356 } 4460 }
4357 dart.setSignature(_HandleErrorStream, { 4461 dart.setSignature(_HandleErrorStream, {
4462 constructors: () => ({_HandleErrorStream: [_HandleErrorStream$(T), [Stream $(T), core.Function, dart.functionType(core.bool, [dart.bottom])]]}),
4358 methods: () => ({[_handleError]: [dart.void, [core.Object, core.StackTrace , _EventSink$(T)]]}) 4463 methods: () => ({[_handleError]: [dart.void, [core.Object, core.StackTrace , _EventSink$(T)]]})
4359 }); 4464 });
4360 return _HandleErrorStream; 4465 return _HandleErrorStream;
4361 }); 4466 });
4362 let _HandleErrorStream = _HandleErrorStream$(); 4467 let _HandleErrorStream = _HandleErrorStream$();
4363 let _remaining = Symbol('_remaining'); 4468 let _remaining = Symbol('_remaining');
4364 let _TakeStream$ = dart.generic(function(T) { 4469 let _TakeStream$ = dart.generic(function(T) {
4365 class _TakeStream extends _ForwardingStream$(T, T) { 4470 class _TakeStream extends _ForwardingStream$(T, T) {
4366 _TakeStream(source, count) { 4471 _TakeStream(source, count) {
4367 this[_remaining] = count; 4472 this[_remaining] = count;
4368 super._ForwardingStream(source); 4473 super._ForwardingStream(source);
4369 if (!(typeof count == 'number')) 4474 if (!(typeof count == 'number'))
4370 throw new core.ArgumentError(count); 4475 throw new core.ArgumentError(count);
4371 } 4476 }
4372 [_handleData](inputEvent, sink) { 4477 [_handleData](inputEvent, sink) {
4373 dart.as(inputEvent, T); 4478 dart.as(inputEvent, T);
4374 dart.as(sink, _EventSink$(T)); 4479 dart.as(sink, _EventSink$(T));
4375 if (dart.notNull(this[_remaining]) > 0) { 4480 if (dart.notNull(this[_remaining]) > 0) {
4376 sink[_add](inputEvent); 4481 sink[_add](inputEvent);
4377 this[_remaining] = dart.notNull(this[_remaining]) - 1; 4482 this[_remaining] = dart.notNull(this[_remaining]) - 1;
4378 if (this[_remaining] == 0) { 4483 if (this[_remaining] == 0) {
4379 sink[_close](); 4484 sink[_close]();
4380 } 4485 }
4381 } 4486 }
4382 } 4487 }
4383 } 4488 }
4384 dart.setSignature(_TakeStream, { 4489 dart.setSignature(_TakeStream, {
4490 constructors: () => ({_TakeStream: [_TakeStream$(T), [Stream$(T), core.int ]]}),
4385 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4491 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4386 }); 4492 });
4387 return _TakeStream; 4493 return _TakeStream;
4388 }); 4494 });
4389 let _TakeStream = _TakeStream$(); 4495 let _TakeStream = _TakeStream$();
4390 let _TakeWhileStream$ = dart.generic(function(T) { 4496 let _TakeWhileStream$ = dart.generic(function(T) {
4391 class _TakeWhileStream extends _ForwardingStream$(T, T) { 4497 class _TakeWhileStream extends _ForwardingStream$(T, T) {
4392 _TakeWhileStream(source, test) { 4498 _TakeWhileStream(source, test) {
4393 this[_test] = test; 4499 this[_test] = test;
4394 super._ForwardingStream(source); 4500 super._ForwardingStream(source);
(...skipping 12 matching lines...) Expand all
4407 } 4513 }
4408 4514
4409 if (satisfies) { 4515 if (satisfies) {
4410 sink[_add](inputEvent); 4516 sink[_add](inputEvent);
4411 } else { 4517 } else {
4412 sink[_close](); 4518 sink[_close]();
4413 } 4519 }
4414 } 4520 }
4415 } 4521 }
4416 dart.setSignature(_TakeWhileStream, { 4522 dart.setSignature(_TakeWhileStream, {
4523 constructors: () => ({_TakeWhileStream: [_TakeWhileStream$(T), [Stream$(T) , dart.functionType(core.bool, [T])]]}),
4417 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4524 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4418 }); 4525 });
4419 return _TakeWhileStream; 4526 return _TakeWhileStream;
4420 }); 4527 });
4421 let _TakeWhileStream = _TakeWhileStream$(); 4528 let _TakeWhileStream = _TakeWhileStream$();
4422 let _SkipStream$ = dart.generic(function(T) { 4529 let _SkipStream$ = dart.generic(function(T) {
4423 class _SkipStream extends _ForwardingStream$(T, T) { 4530 class _SkipStream extends _ForwardingStream$(T, T) {
4424 _SkipStream(source, count) { 4531 _SkipStream(source, count) {
4425 this[_remaining] = count; 4532 this[_remaining] = count;
4426 super._ForwardingStream(source); 4533 super._ForwardingStream(source);
4427 if (!(typeof count == 'number') || dart.notNull(count) < 0) 4534 if (!(typeof count == 'number') || dart.notNull(count) < 0)
4428 throw new core.ArgumentError(count); 4535 throw new core.ArgumentError(count);
4429 } 4536 }
4430 [_handleData](inputEvent, sink) { 4537 [_handleData](inputEvent, sink) {
4431 dart.as(inputEvent, T); 4538 dart.as(inputEvent, T);
4432 dart.as(sink, _EventSink$(T)); 4539 dart.as(sink, _EventSink$(T));
4433 if (dart.notNull(this[_remaining]) > 0) { 4540 if (dart.notNull(this[_remaining]) > 0) {
4434 this[_remaining] = dart.notNull(this[_remaining]) - 1; 4541 this[_remaining] = dart.notNull(this[_remaining]) - 1;
4435 return; 4542 return;
4436 } 4543 }
4437 sink[_add](inputEvent); 4544 sink[_add](inputEvent);
4438 } 4545 }
4439 } 4546 }
4440 dart.setSignature(_SkipStream, { 4547 dart.setSignature(_SkipStream, {
4548 constructors: () => ({_SkipStream: [_SkipStream$(T), [Stream$(T), core.int ]]}),
4441 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4549 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4442 }); 4550 });
4443 return _SkipStream; 4551 return _SkipStream;
4444 }); 4552 });
4445 let _SkipStream = _SkipStream$(); 4553 let _SkipStream = _SkipStream$();
4446 let _hasFailed = Symbol('_hasFailed'); 4554 let _hasFailed = Symbol('_hasFailed');
4447 let _SkipWhileStream$ = dart.generic(function(T) { 4555 let _SkipWhileStream$ = dart.generic(function(T) {
4448 class _SkipWhileStream extends _ForwardingStream$(T, T) { 4556 class _SkipWhileStream extends _ForwardingStream$(T, T) {
4449 _SkipWhileStream(source, test) { 4557 _SkipWhileStream(source, test) {
4450 this[_test] = test; 4558 this[_test] = test;
(...skipping 17 matching lines...) Expand all
4468 return; 4576 return;
4469 } 4577 }
4470 4578
4471 if (!dart.notNull(satisfies)) { 4579 if (!dart.notNull(satisfies)) {
4472 this[_hasFailed] = true; 4580 this[_hasFailed] = true;
4473 sink[_add](inputEvent); 4581 sink[_add](inputEvent);
4474 } 4582 }
4475 } 4583 }
4476 } 4584 }
4477 dart.setSignature(_SkipWhileStream, { 4585 dart.setSignature(_SkipWhileStream, {
4586 constructors: () => ({_SkipWhileStream: [_SkipWhileStream$(T), [Stream$(T) , dart.functionType(core.bool, [T])]]}),
4478 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4587 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4479 }); 4588 });
4480 return _SkipWhileStream; 4589 return _SkipWhileStream;
4481 }); 4590 });
4482 let _SkipWhileStream = _SkipWhileStream$(); 4591 let _SkipWhileStream = _SkipWhileStream$();
4483 let _Equality$ = dart.generic(function(T) { 4592 let _Equality$ = dart.generic(function(T) {
4484 let _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool, [T, T])); 4593 let _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool, [T, T]));
4485 return _Equality; 4594 return _Equality;
4486 }); 4595 });
4487 let _Equality = _Equality$(); 4596 let _Equality = _Equality$();
(...skipping 26 matching lines...) Expand all
4514 } 4623 }
4515 4624
4516 if (!dart.notNull(isEqual)) { 4625 if (!dart.notNull(isEqual)) {
4517 sink[_add](inputEvent); 4626 sink[_add](inputEvent);
4518 this[_previous] = inputEvent; 4627 this[_previous] = inputEvent;
4519 } 4628 }
4520 } 4629 }
4521 } 4630 }
4522 } 4631 }
4523 dart.setSignature(_DistinctStream, { 4632 dart.setSignature(_DistinctStream, {
4633 constructors: () => ({_DistinctStream: [_DistinctStream$(T), [Stream$(T), dart.functionType(core.bool, [T, T])]]}),
4524 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4634 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4525 }); 4635 });
4526 return _DistinctStream; 4636 return _DistinctStream;
4527 }); 4637 });
4528 let _DistinctStream = _DistinctStream$(); 4638 let _DistinctStream = _DistinctStream$();
4529 dart.defineLazyProperties(_DistinctStream, { 4639 dart.defineLazyProperties(_DistinctStream, {
4530 get _SENTINEL() { 4640 get _SENTINEL() {
4531 return new core.Object(); 4641 return new core.Object();
4532 }, 4642 },
4533 set _SENTINEL(_) {} 4643 set _SENTINEL(_) {}
(...skipping 11 matching lines...) Expand all
4545 if (stackTrace === void 0) 4655 if (stackTrace === void 0)
4546 stackTrace = null; 4656 stackTrace = null;
4547 this[_sink][_addError](error, stackTrace); 4657 this[_sink][_addError](error, stackTrace);
4548 } 4658 }
4549 close() { 4659 close() {
4550 this[_sink][_close](); 4660 this[_sink][_close]();
4551 } 4661 }
4552 } 4662 }
4553 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; 4663 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)];
4554 dart.setSignature(_EventSinkWrapper, { 4664 dart.setSignature(_EventSinkWrapper, {
4665 constructors: () => ({_EventSinkWrapper: [_EventSinkWrapper$(T), [_EventSi nk]]}),
4555 methods: () => ({ 4666 methods: () => ({
4556 add: [dart.void, [T]], 4667 add: [dart.void, [T]],
4557 addError: [dart.void, [core.Object], [core.StackTrace]], 4668 addError: [dart.void, [core.Object], [core.StackTrace]],
4558 close: [dart.void, []] 4669 close: [dart.void, []]
4559 }) 4670 })
4560 }); 4671 });
4561 return _EventSinkWrapper; 4672 return _EventSinkWrapper;
4562 }); 4673 });
4563 let _EventSinkWrapper = _EventSinkWrapper$(); 4674 let _EventSinkWrapper = _EventSinkWrapper$();
4564 let _transformerSink = Symbol('_transformerSink'); 4675 let _transformerSink = Symbol('_transformerSink');
(...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after
4641 this[_subscription] = null; 4752 this[_subscription] = null;
4642 this[_transformerSink].close(); 4753 this[_transformerSink].close();
4643 } catch (e) { 4754 } catch (e) {
4644 let s = dart.stackTrace(e); 4755 let s = dart.stackTrace(e);
4645 this[_addError](e, s); 4756 this[_addError](e, s);
4646 } 4757 }
4647 4758
4648 } 4759 }
4649 } 4760 }
4650 dart.setSignature(_SinkTransformerStreamSubscription, { 4761 dart.setSignature(_SinkTransformerStreamSubscription, {
4762 constructors: () => ({_SinkTransformerStreamSubscription: [_SinkTransforme rStreamSubscription$(S, T), [Stream$(S), _SinkMapper$(S, T), dart.functionType(d art.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}),
4651 methods: () => ({ 4763 methods: () => ({
4652 [_add]: [dart.void, [T]], 4764 [_add]: [dart.void, [T]],
4653 [_handleData]: [dart.void, [S]], 4765 [_handleData]: [dart.void, [S]],
4654 [_handleError]: [dart.void, [core.Object], [core.Object]], 4766 [_handleError]: [dart.void, [core.Object], [core.Object]],
4655 [_handleDone]: [dart.void, []] 4767 [_handleDone]: [dart.void, []]
4656 }) 4768 })
4657 }); 4769 });
4658 return _SinkTransformerStreamSubscription; 4770 return _SinkTransformerStreamSubscription;
4659 }); 4771 });
4660 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$() ; 4772 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$() ;
4661 let _SinkMapper$ = dart.generic(function(S, T) { 4773 let _SinkMapper$ = dart.generic(function(S, T) {
4662 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS ink$(S), [EventSink$(T)])); 4774 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS ink$(S), [EventSink$(T)]));
4663 return _SinkMapper; 4775 return _SinkMapper;
4664 }); 4776 });
4665 let _SinkMapper = _SinkMapper$(); 4777 let _SinkMapper = _SinkMapper$();
4666 let _sinkMapper = Symbol('_sinkMapper'); 4778 let _sinkMapper = Symbol('_sinkMapper');
4667 let _StreamSinkTransformer$ = dart.generic(function(S, T) { 4779 let _StreamSinkTransformer$ = dart.generic(function(S, T) {
4668 class _StreamSinkTransformer extends core.Object { 4780 class _StreamSinkTransformer extends core.Object {
4669 _StreamSinkTransformer(sinkMapper) { 4781 _StreamSinkTransformer(sinkMapper) {
4670 this[_sinkMapper] = sinkMapper; 4782 this[_sinkMapper] = sinkMapper;
4671 } 4783 }
4672 bind(stream) { 4784 bind(stream) {
4673 dart.as(stream, Stream$(S)); 4785 dart.as(stream, Stream$(S));
4674 return new (_BoundSinkStream$(S, T))(stream, this[_sinkMapper]); 4786 return new (_BoundSinkStream$(S, T))(stream, this[_sinkMapper]);
4675 } 4787 }
4676 } 4788 }
4677 _StreamSinkTransformer[dart.implements] = () => [StreamTransformer$(S, T)]; 4789 _StreamSinkTransformer[dart.implements] = () => [StreamTransformer$(S, T)];
4678 dart.setSignature(_StreamSinkTransformer, { 4790 dart.setSignature(_StreamSinkTransformer, {
4791 constructors: () => ({_StreamSinkTransformer: [_StreamSinkTransformer$(S, T), [_SinkMapper$(S, T)]]}),
4679 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}) 4792 methods: () => ({bind: [Stream$(T), [Stream$(S)]]})
4680 }); 4793 });
4681 return _StreamSinkTransformer; 4794 return _StreamSinkTransformer;
4682 }); 4795 });
4683 let _StreamSinkTransformer = _StreamSinkTransformer$(); 4796 let _StreamSinkTransformer = _StreamSinkTransformer$();
4684 let _BoundSinkStream$ = dart.generic(function(S, T) { 4797 let _BoundSinkStream$ = dart.generic(function(S, T) {
4685 class _BoundSinkStream extends Stream$(T) { 4798 class _BoundSinkStream extends Stream$(T) {
4686 get isBroadcast() { 4799 get isBroadcast() {
4687 return this[_stream].isBroadcast; 4800 return this[_stream].isBroadcast;
4688 } 4801 }
4689 _BoundSinkStream(stream, sinkMapper) { 4802 _BoundSinkStream(stream, sinkMapper) {
4690 this[_stream] = stream; 4803 this[_stream] = stream;
4691 this[_sinkMapper] = sinkMapper; 4804 this[_sinkMapper] = sinkMapper;
4692 super.Stream(); 4805 super.Stream();
4693 } 4806 }
4694 listen(onData, opts) { 4807 listen(onData, opts) {
4695 dart.as(onData, dart.functionType(dart.void, [T])); 4808 dart.as(onData, dart.functionType(dart.void, [T]));
4696 let onError = opts && 'onError' in opts ? opts.onError : null; 4809 let onError = opts && 'onError' in opts ? opts.onError : null;
4697 let onDone = opts && 'onDone' in opts ? opts.onDone : null; 4810 let onDone = opts && 'onDone' in opts ? opts.onDone : null;
4698 dart.as(onDone, dart.functionType(dart.void, [])); 4811 dart.as(onDone, dart.functionType(dart.void, []));
4699 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 4812 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
4700 cancelOnError = core.identical(true, cancelOnError); 4813 cancelOnError = core.identical(true, cancelOnError);
4701 let subscription = new (_SinkTransformerStreamSubscription$(core.Object, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, on Done, cancelOnError); 4814 let subscription = new (_SinkTransformerStreamSubscription$(core.Object, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, on Done, cancelOnError);
4702 return subscription; 4815 return subscription;
4703 } 4816 }
4704 } 4817 }
4705 dart.setSignature(_BoundSinkStream, { 4818 dart.setSignature(_BoundSinkStream, {
4819 constructors: () => ({_BoundSinkStream: [_BoundSinkStream$(S, T), [Stream$ (S), _SinkMapper$(S, T)]]}),
4706 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart. void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance lOnErro: core.bool}]}) 4820 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart. void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance lOnErro: core.bool}]})
4707 }); 4821 });
4708 return _BoundSinkStream; 4822 return _BoundSinkStream;
4709 }); 4823 });
4710 let _BoundSinkStream = _BoundSinkStream$(); 4824 let _BoundSinkStream = _BoundSinkStream$();
4711 let _TransformDataHandler$ = dart.generic(function(S, T) { 4825 let _TransformDataHandler$ = dart.generic(function(S, T) {
4712 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart .functionType(dart.void, [S, EventSink$(T)])); 4826 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart .functionType(dart.void, [S, EventSink$(T)]));
4713 return _TransformDataHandler; 4827 return _TransformDataHandler;
4714 }); 4828 });
4715 let _TransformDataHandler = _TransformDataHandler$(); 4829 let _TransformDataHandler = _TransformDataHandler$();
(...skipping 23 matching lines...) Expand all
4739 if (stackTrace === void 0) 4853 if (stackTrace === void 0)
4740 stackTrace = null; 4854 stackTrace = null;
4741 return this[_handleError](error, stackTrace, this[_sink]); 4855 return this[_handleError](error, stackTrace, this[_sink]);
4742 } 4856 }
4743 close() { 4857 close() {
4744 return this[_handleDone](this[_sink]); 4858 return this[_handleDone](this[_sink]);
4745 } 4859 }
4746 } 4860 }
4747 _HandlerEventSink[dart.implements] = () => [EventSink$(S)]; 4861 _HandlerEventSink[dart.implements] = () => [EventSink$(S)];
4748 dart.setSignature(_HandlerEventSink, { 4862 dart.setSignature(_HandlerEventSink, {
4863 constructors: () => ({_HandlerEventSink: [_HandlerEventSink$(S, T), [_Tran sformDataHandler$(S, T), _TransformErrorHandler$(T), _TransformDoneHandler$(T), EventSink$(T)]]}),
4749 methods: () => ({ 4864 methods: () => ({
4750 add: [dart.void, [S]], 4865 add: [dart.void, [S]],
4751 addError: [dart.void, [core.Object], [core.StackTrace]], 4866 addError: [dart.void, [core.Object], [core.StackTrace]],
4752 close: [dart.void, []] 4867 close: [dart.void, []]
4753 }) 4868 })
4754 }); 4869 });
4755 return _HandlerEventSink; 4870 return _HandlerEventSink;
4756 }); 4871 });
4757 let _HandlerEventSink = _HandlerEventSink$(); 4872 let _HandlerEventSink = _HandlerEventSink$();
4758 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { 4873 let _StreamHandlerTransformer$ = dart.generic(function(S, T) {
(...skipping 21 matching lines...) Expand all
4780 sink.add(data); 4895 sink.add(data);
4781 } 4896 }
4782 static _defaultHandleError(error, stackTrace, sink) { 4897 static _defaultHandleError(error, stackTrace, sink) {
4783 sink.addError(error); 4898 sink.addError(error);
4784 } 4899 }
4785 static _defaultHandleDone(sink) { 4900 static _defaultHandleDone(sink) {
4786 sink.close(); 4901 sink.close();
4787 } 4902 }
4788 } 4903 }
4789 dart.setSignature(_StreamHandlerTransformer, { 4904 dart.setSignature(_StreamHandlerTransformer, {
4905 constructors: () => ({_StreamHandlerTransformer: [_StreamHandlerTransforme r$(S, T), [], {andleDat: dart.functionType(dart.void, [S, EventSink$(T)]), andle Erro: dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)] ), andleDon: dart.functionType(dart.void, [EventSink$(T)])}]}),
4790 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}), 4906 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}),
4791 statics: () => ({ 4907 statics: () => ({
4792 _defaultHandleData: [dart.void, [core.Object, EventSink]], 4908 _defaultHandleData: [dart.void, [core.Object, EventSink]],
4793 _defaultHandleError: [dart.void, [core.Object, core.StackTrace, EventSin k]], 4909 _defaultHandleError: [dart.void, [core.Object, core.StackTrace, EventSin k]],
4794 _defaultHandleDone: [dart.void, [EventSink]] 4910 _defaultHandleDone: [dart.void, [EventSink]]
4795 }), 4911 }),
4796 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] 4912 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone']
4797 }); 4913 });
4798 return _StreamHandlerTransformer; 4914 return _StreamHandlerTransformer;
4799 }); 4915 });
4800 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); 4916 let _StreamHandlerTransformer = _StreamHandlerTransformer$();
4801 let _SubscriptionTransformer$ = dart.generic(function(S, T) { 4917 let _SubscriptionTransformer$ = dart.generic(function(S, T) {
4802 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () = > dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); 4918 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () = > dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool]));
4803 return _SubscriptionTransformer; 4919 return _SubscriptionTransformer;
4804 }); 4920 });
4805 let _SubscriptionTransformer = _SubscriptionTransformer$(); 4921 let _SubscriptionTransformer = _SubscriptionTransformer$();
4806 let _transformer = Symbol('_transformer'); 4922 let _transformer = Symbol('_transformer');
4807 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { 4923 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {
4808 class _StreamSubscriptionTransformer extends core.Object { 4924 class _StreamSubscriptionTransformer extends core.Object {
4809 _StreamSubscriptionTransformer(transformer) { 4925 _StreamSubscriptionTransformer(transformer) {
4810 this[_transformer] = transformer; 4926 this[_transformer] = transformer;
4811 } 4927 }
4812 bind(stream) { 4928 bind(stream) {
4813 dart.as(stream, Stream$(S)); 4929 dart.as(stream, Stream$(S));
4814 return new (_BoundSubscriptionStream$(S, T))(stream, this[_transformer]) ; 4930 return new (_BoundSubscriptionStream$(S, T))(stream, this[_transformer]) ;
4815 } 4931 }
4816 } 4932 }
4817 _StreamSubscriptionTransformer[dart.implements] = () => [StreamTransformer$( S, T)]; 4933 _StreamSubscriptionTransformer[dart.implements] = () => [StreamTransformer$( S, T)];
4818 dart.setSignature(_StreamSubscriptionTransformer, { 4934 dart.setSignature(_StreamSubscriptionTransformer, {
4935 constructors: () => ({_StreamSubscriptionTransformer: [_StreamSubscription Transformer$(S, T), [_SubscriptionTransformer$(S, T)]]}),
4819 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}) 4936 methods: () => ({bind: [Stream$(T), [Stream$(S)]]})
4820 }); 4937 });
4821 return _StreamSubscriptionTransformer; 4938 return _StreamSubscriptionTransformer;
4822 }); 4939 });
4823 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(); 4940 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$();
4824 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { 4941 let _BoundSubscriptionStream$ = dart.generic(function(S, T) {
4825 class _BoundSubscriptionStream extends Stream$(T) { 4942 class _BoundSubscriptionStream extends Stream$(T) {
4826 _BoundSubscriptionStream(stream, transformer) { 4943 _BoundSubscriptionStream(stream, transformer) {
4827 this[_stream] = stream; 4944 this[_stream] = stream;
4828 this[_transformer] = transformer; 4945 this[_transformer] = transformer;
4829 super.Stream(); 4946 super.Stream();
4830 } 4947 }
4831 listen(onData, opts) { 4948 listen(onData, opts) {
4832 dart.as(onData, dart.functionType(dart.void, [T])); 4949 dart.as(onData, dart.functionType(dart.void, [T]));
4833 let onError = opts && 'onError' in opts ? opts.onError : null; 4950 let onError = opts && 'onError' in opts ? opts.onError : null;
4834 let onDone = opts && 'onDone' in opts ? opts.onDone : null; 4951 let onDone = opts && 'onDone' in opts ? opts.onDone : null;
4835 dart.as(onDone, dart.functionType(dart.void, [])); 4952 dart.as(onDone, dart.functionType(dart.void, []));
4836 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 4953 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
4837 cancelOnError = core.identical(true, cancelOnError); 4954 cancelOnError = core.identical(true, cancelOnError);
4838 let result = this[_transformer](this[_stream], cancelOnError); 4955 let result = this[_transformer](this[_stream], cancelOnError);
4839 result.onData(onData); 4956 result.onData(onData);
4840 result.onError(onError); 4957 result.onError(onError);
4841 result.onDone(onDone); 4958 result.onDone(onDone);
4842 return result; 4959 return result;
4843 } 4960 }
4844 } 4961 }
4845 dart.setSignature(_BoundSubscriptionStream, { 4962 dart.setSignature(_BoundSubscriptionStream, {
4963 constructors: () => ({_BoundSubscriptionStream: [_BoundSubscriptionStream$ (S, T), [Stream$(S), _SubscriptionTransformer$(S, T)]]}),
4846 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart. void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance lOnErro: core.bool}]}) 4964 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart. void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance lOnErro: core.bool}]})
4847 }); 4965 });
4848 return _BoundSubscriptionStream; 4966 return _BoundSubscriptionStream;
4849 }); 4967 });
4850 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); 4968 let _BoundSubscriptionStream = _BoundSubscriptionStream$();
4851 let __CastType27$ = dart.generic(function(S, T) { 4969 let __CastType27$ = dart.generic(function(S, T) {
4852 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart .void, [S, EventSink$(T)])); 4970 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart .void, [S, EventSink$(T)]));
4853 return __CastType27; 4971 return __CastType27;
4854 }); 4972 });
4855 let __CastType27 = __CastType27$(); 4973 let __CastType27 = __CastType27$();
(...skipping 26 matching lines...) Expand all
4882 } 5000 }
4883 static _createPeriodicTimer(duration, callback) { 5001 static _createPeriodicTimer(duration, callback) {
4884 let milliseconds = duration.inMilliseconds; 5002 let milliseconds = duration.inMilliseconds;
4885 if (dart.notNull(milliseconds) < 0) 5003 if (dart.notNull(milliseconds) < 0)
4886 milliseconds = 0; 5004 milliseconds = 0;
4887 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); 5005 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback);
4888 } 5006 }
4889 } 5007 }
4890 dart.defineNamedConstructor(Timer, 'periodic'); 5008 dart.defineNamedConstructor(Timer, 'periodic');
4891 dart.setSignature(Timer, { 5009 dart.setSignature(Timer, {
5010 constructors: () => ({
5011 Timer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
5012 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]]
5013 }),
4892 statics: () => ({ 5014 statics: () => ({
4893 run: [dart.void, [dart.functionType(dart.void, [])]], 5015 run: [dart.void, [dart.functionType(dart.void, [])]],
4894 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], 5016 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
4895 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] 5017 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]]
4896 }), 5018 }),
4897 names: ['run', '_createTimer', '_createPeriodicTimer'] 5019 names: ['run', '_createTimer', '_createPeriodicTimer']
4898 }); 5020 });
4899 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v oid, [Timer])); 5021 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v oid, [Timer]));
4900 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(core.O bject, [])); 5022 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(core.O bject, []));
4901 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT ype(core.Object, [dart.bottom])); 5023 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT ype(core.Object, [dart.bottom]));
(...skipping 10 matching lines...) Expand all
4912 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo id, [])])); 5034 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo id, [])]));
4913 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', () => dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func tionType(dart.void, [Timer])])); 5035 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', () => dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func tionType(dart.void, [Timer])]));
4914 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v oid, [Zone, ZoneDelegate, Zone, core.String])); 5036 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v oid, [Zone, ZoneDelegate, Zone, core.String]));
4915 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); 5037 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z one, ZoneDelegate, Zone, ZoneSpecification, core.Map]));
4916 class _ZoneFunction extends core.Object { 5038 class _ZoneFunction extends core.Object {
4917 _ZoneFunction(zone, func) { 5039 _ZoneFunction(zone, func) {
4918 this.zone = zone; 5040 this.zone = zone;
4919 this.function = func; 5041 this.function = func;
4920 } 5042 }
4921 } 5043 }
5044 dart.setSignature(_ZoneFunction, {
5045 constructors: () => ({_ZoneFunction: [_ZoneFunction, [_Zone, core.Function]] })
5046 });
4922 class ZoneSpecification extends core.Object { 5047 class ZoneSpecification extends core.Object {
4923 ZoneSpecification(opts) { 5048 ZoneSpecification(opts) {
4924 return new _ZoneSpecification(opts); 5049 return new _ZoneSpecification(opts);
4925 } 5050 }
4926 from(other, opts) { 5051 from(other, opts) {
4927 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null; 5052 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null;
4928 let run = opts && 'run' in opts ? opts.run : null; 5053 let run = opts && 'run' in opts ? opts.run : null;
4929 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; 5054 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null;
4930 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; 5055 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null;
4931 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null; 5056 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null;
4932 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null; 5057 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null;
4933 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null; 5058 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null;
4934 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null; 5059 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null;
4935 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul eMicrotask : null; 5060 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul eMicrotask : null;
4936 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; 5061 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null;
4937 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre atePeriodicTimer : null; 5062 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre atePeriodicTimer : null;
4938 let print = opts && 'print' in opts ? opts.print : null; 5063 let print = opts && 'print' in opts ? opts.print : null;
4939 let fork = opts && 'fork' in opts ? opts.fork : null; 5064 let fork = opts && 'fork' in opts ? opts.fork : null;
4940 return new ZoneSpecification({handleUncaughtError: handleUncaughtError != null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run : other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null ? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print : other.print, fork: fork != null ? fork : other.fork}); 5065 return new ZoneSpecification({handleUncaughtError: handleUncaughtError != null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run : other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null ? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print : other.print, fork: fork != null ? fork : other.fork});
4941 } 5066 }
4942 } 5067 }
4943 dart.defineNamedConstructor(ZoneSpecification, 'from'); 5068 dart.defineNamedConstructor(ZoneSpecification, 'from');
5069 dart.setSignature(ZoneSpecification, {
5070 constructors: () => ({
5071 ZoneSpecification: [ZoneSpecification, [], {andleUncaughtErro: dart.functi onType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrace]), u : dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(co re.Object, [])]), unUnar: dart.functionType(core.Object, [Zone, ZoneDelegate, Zo ne, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), unBinar: dart. functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Obje ct, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), egisterCallbac: dar t.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(core.O bject, [])]), egisterUnaryCallbac: dart.functionType(ZoneUnaryCallback, [Zone, Z oneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])]), egisterBinar yCallbac: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart. functionType(core.Object, [dart.bottom, dart.bottom])]), rrorCallbac: dart.funct ionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]), c heduleMicrotas: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.fun ctionType(core.Object, [])]), reateTime: dart.functionType(Timer, [Zone, ZoneDel egate, Zone, core.Duration, dart.functionType(dart.void, [])]), reatePeriodicTim e: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.funct ionType(dart.void, [Timer])]), rin: dart.functionType(dart.void, [Zone, ZoneDele gate, Zone, core.String]), or: dart.functionType(Zone, [Zone, ZoneDelegate, Zone , ZoneSpecification, core.Map])}],
5072 from: [ZoneSpecification, [ZoneSpecification], {andleUncaughtErro: dart.fu nctionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrace] ), u: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionTyp e(core.Object, [])]), unUnar: dart.functionType(core.Object, [Zone, ZoneDelegate , Zone, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), unBinar: d art.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core. Object, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), egisterCallbac: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(co re.Object, [])]), egisterUnaryCallbac: dart.functionType(ZoneUnaryCallback, [Zon e, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])]), egisterB inaryCallbac: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, d art.functionType(core.Object, [dart.bottom, dart.bottom])]), rrorCallbac: dart.f unctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace] ), cheduleMicrotas: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart .functionType(core.Object, [])]), reateTime: dart.functionType(Timer, [Zone, Zon eDelegate, Zone, core.Duration, dart.functionType(dart.void, [])]), reatePeriodi cTime: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.f unctionType(dart.void, [Timer])]), rin: dart.functionType(dart.void, [Zone, Zone Delegate, Zone, core.String]), or: dart.functionType(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}]
5073 })
5074 });
4944 class _ZoneSpecification extends core.Object { 5075 class _ZoneSpecification extends core.Object {
4945 _ZoneSpecification(opts) { 5076 _ZoneSpecification(opts) {
4946 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null; 5077 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null;
4947 let run = opts && 'run' in opts ? opts.run : null; 5078 let run = opts && 'run' in opts ? opts.run : null;
4948 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; 5079 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null;
4949 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; 5080 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null;
4950 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null; 5081 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null;
4951 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null; 5082 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null;
4952 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null; 5083 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null;
4953 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null; 5084 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null;
(...skipping 11 matching lines...) Expand all
4965 this.registerBinaryCallback = registerBinaryCallback; 5096 this.registerBinaryCallback = registerBinaryCallback;
4966 this.errorCallback = errorCallback; 5097 this.errorCallback = errorCallback;
4967 this.scheduleMicrotask = scheduleMicrotask; 5098 this.scheduleMicrotask = scheduleMicrotask;
4968 this.createTimer = createTimer; 5099 this.createTimer = createTimer;
4969 this.createPeriodicTimer = createPeriodicTimer; 5100 this.createPeriodicTimer = createPeriodicTimer;
4970 this.print = print; 5101 this.print = print;
4971 this.fork = fork; 5102 this.fork = fork;
4972 } 5103 }
4973 } 5104 }
4974 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; 5105 _ZoneSpecification[dart.implements] = () => [ZoneSpecification];
5106 dart.setSignature(_ZoneSpecification, {
5107 constructors: () => ({_ZoneSpecification: [_ZoneSpecification, [], {andleUnc aughtErro: core.Object, u: core.Object, unUnar: core.Object, unBinar: core.Objec t, egisterCallbac: core.Object, egisterUnaryCallbac: core.Object, egisterBinaryC allbac: core.Object, rrorCallbac: core.Object, cheduleMicrotas: core.Object, rea teTime: core.Object, reatePeriodicTime: core.Object, rin: core.Object, or: core. Object}]})
5108 });
4975 class ZoneDelegate extends core.Object {} 5109 class ZoneDelegate extends core.Object {}
4976 class Zone extends core.Object { 5110 class Zone extends core.Object {
4977 _() { 5111 _() {
4978 } 5112 }
4979 static get current() { 5113 static get current() {
4980 return Zone._current; 5114 return Zone._current;
4981 } 5115 }
4982 static _enter(zone) { 5116 static _enter(zone) {
4983 dart.assert(zone != null); 5117 dart.assert(zone != null);
4984 dart.assert(!dart.notNull(core.identical(zone, Zone._current))); 5118 dart.assert(!dart.notNull(core.identical(zone, Zone._current)));
4985 let previous = Zone._current; 5119 let previous = Zone._current;
4986 Zone._current = zone; 5120 Zone._current = zone;
4987 return previous; 5121 return previous;
4988 } 5122 }
4989 static _leave(previous) { 5123 static _leave(previous) {
4990 dart.assert(previous != null); 5124 dart.assert(previous != null);
4991 Zone._current = previous; 5125 Zone._current = previous;
4992 } 5126 }
4993 } 5127 }
4994 dart.defineNamedConstructor(Zone, '_'); 5128 dart.defineNamedConstructor(Zone, '_');
4995 dart.setSignature(Zone, { 5129 dart.setSignature(Zone, {
5130 constructors: () => ({_: [Zone, []]}),
4996 statics: () => ({ 5131 statics: () => ({
4997 _enter: [Zone, [Zone]], 5132 _enter: [Zone, [Zone]],
4998 _leave: [dart.void, [Zone]] 5133 _leave: [dart.void, [Zone]]
4999 }), 5134 }),
5000 names: ['_enter', '_leave'] 5135 names: ['_enter', '_leave']
5001 }); 5136 });
5002 class _Zone extends core.Object { 5137 class _Zone extends core.Object {
5003 _Zone() { 5138 _Zone() {
5004 } 5139 }
5005 inSameErrorZone(otherZone) { 5140 inSameErrorZone(otherZone) {
5006 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone)); 5141 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone));
5007 } 5142 }
5008 } 5143 }
5009 _Zone[dart.implements] = () => [Zone]; 5144 _Zone[dart.implements] = () => [Zone];
5010 dart.setSignature(_Zone, { 5145 dart.setSignature(_Zone, {
5146 constructors: () => ({_Zone: [_Zone, []]}),
5011 methods: () => ({inSameErrorZone: [core.bool, [Zone]]}) 5147 methods: () => ({inSameErrorZone: [core.bool, [Zone]]})
5012 }); 5148 });
5013 let _run = Symbol('_run'); 5149 let _run = Symbol('_run');
5014 let _runUnary = Symbol('_runUnary'); 5150 let _runUnary = Symbol('_runUnary');
5015 let _runBinary = Symbol('_runBinary'); 5151 let _runBinary = Symbol('_runBinary');
5016 let _registerCallback = Symbol('_registerCallback'); 5152 let _registerCallback = Symbol('_registerCallback');
5017 let _registerUnaryCallback = Symbol('_registerUnaryCallback'); 5153 let _registerUnaryCallback = Symbol('_registerUnaryCallback');
5018 let _registerBinaryCallback = Symbol('_registerBinaryCallback'); 5154 let _registerBinaryCallback = Symbol('_registerBinaryCallback');
5019 let _errorCallback = Symbol('_errorCallback'); 5155 let _errorCallback = Symbol('_errorCallback');
5020 let _scheduleMicrotask = Symbol('_scheduleMicrotask'); 5156 let _scheduleMicrotask = Symbol('_scheduleMicrotask');
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after
5187 return Timer._createTimer(duration, f); 5323 return Timer._createTimer(duration, f);
5188 } 5324 }
5189 createPeriodicTimer(duration, f) { 5325 createPeriodicTimer(duration, f) {
5190 return Timer._createPeriodicTimer(duration, f); 5326 return Timer._createPeriodicTimer(duration, f);
5191 } 5327 }
5192 print(line) { 5328 print(line) {
5193 _internal.printToConsole(line); 5329 _internal.printToConsole(line);
5194 } 5330 }
5195 } 5331 }
5196 dart.setSignature(_RootZone, { 5332 dart.setSignature(_RootZone, {
5333 constructors: () => ({_RootZone: [_RootZone, []]}),
5197 methods: () => ({ 5334 methods: () => ({
5198 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], 5335 runGuarded: [core.Object, [dart.functionType(core.Object, [])]],
5199 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto m]), core.Object]], 5336 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto m]), core.Object]],
5200 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott om, dart.bottom]), core.Object, core.Object]], 5337 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott om, dart.bottom]), core.Object, core.Object]],
5201 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {unGuar de: core.bool}], 5338 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {unGuar de: core.bool}],
5202 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da rt.bottom])], {unGuarde: core.bool}], 5339 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da rt.bottom])], {unGuarde: core.bool}],
5203 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [ dart.bottom, dart.bottom])], {unGuarde: core.bool}], 5340 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [ dart.bottom, dart.bottom])], {unGuarde: core.bool}],
5204 get: [core.Object, [core.Object]], 5341 get: [core.Object, [core.Object]],
5205 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], 5342 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]],
5206 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}], 5343 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}],
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
5294 dart.dcall(implementation.function, implZone, _parentDelegate(implZone), z one, line); 5431 dart.dcall(implementation.function, implZone, _parentDelegate(implZone), z one, line);
5295 } 5432 }
5296 fork(zone, specification, zoneValues) { 5433 fork(zone, specification, zoneValues) {
5297 let implementation = this[_delegationTarget][_fork]; 5434 let implementation = this[_delegationTarget][_fork];
5298 let implZone = implementation.zone; 5435 let implZone = implementation.zone;
5299 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega te(implZone), zone, specification, zoneValues), Zone); 5436 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega te(implZone), zone, specification, zoneValues), Zone);
5300 } 5437 }
5301 } 5438 }
5302 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; 5439 _ZoneDelegate[dart.implements] = () => [ZoneDelegate];
5303 dart.setSignature(_ZoneDelegate, { 5440 dart.setSignature(_ZoneDelegate, {
5441 constructors: () => ({_ZoneDelegate: [_ZoneDelegate, [_Zone]]}),
5304 methods: () => ({ 5442 methods: () => ({
5305 handleUncaughtError: [core.Object, [Zone, core.Object, core.StackTrace]], 5443 handleUncaughtError: [core.Object, [Zone, core.Object, core.StackTrace]],
5306 run: [core.Object, [Zone, dart.functionType(core.Object, [])]], 5444 run: [core.Object, [Zone, dart.functionType(core.Object, [])]],
5307 runUnary: [core.Object, [Zone, dart.functionType(core.Object, [dart.bottom ]), core.Object]], 5445 runUnary: [core.Object, [Zone, dart.functionType(core.Object, [dart.bottom ]), core.Object]],
5308 runBinary: [core.Object, [Zone, dart.functionType(core.Object, [dart.botto m, dart.bottom]), core.Object, core.Object]], 5446 runBinary: [core.Object, [Zone, dart.functionType(core.Object, [dart.botto m, dart.bottom]), core.Object, core.Object]],
5309 registerCallback: [ZoneCallback, [Zone, dart.functionType(core.Object, []) ]], 5447 registerCallback: [ZoneCallback, [Zone, dart.functionType(core.Object, []) ]],
5310 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(core.O bject, [dart.bottom])]], 5448 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(core.O bject, [dart.bottom])]],
5311 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(core .Object, [dart.bottom, dart.bottom])]], 5449 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(core .Object, [dart.bottom, dart.bottom])]],
5312 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]], 5450 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]],
5313 scheduleMicrotask: [dart.void, [Zone, dart.functionType(core.Object, [])]] , 5451 scheduleMicrotask: [dart.void, [Zone, dart.functionType(core.Object, [])]] ,
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after
5506 return dart.as(dart.dcall(implementation.function, implementation.zone, pa rentDelegate, this, duration, f), Timer); 5644 return dart.as(dart.dcall(implementation.function, implementation.zone, pa rentDelegate, this, duration, f), Timer);
5507 } 5645 }
5508 print(line) { 5646 print(line) {
5509 let implementation = this[_print]; 5647 let implementation = this[_print];
5510 dart.assert(implementation != null); 5648 dart.assert(implementation != null);
5511 let parentDelegate = _parentDelegate(implementation.zone); 5649 let parentDelegate = _parentDelegate(implementation.zone);
5512 return dart.dcall(implementation.function, implementation.zone, parentDele gate, this, line); 5650 return dart.dcall(implementation.function, implementation.zone, parentDele gate, this, line);
5513 } 5651 }
5514 } 5652 }
5515 dart.setSignature(_CustomZone, { 5653 dart.setSignature(_CustomZone, {
5654 constructors: () => ({_CustomZone: [_CustomZone, [_Zone, ZoneSpecification, core.Map]]}),
5516 methods: () => ({ 5655 methods: () => ({
5517 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], 5656 runGuarded: [core.Object, [dart.functionType(core.Object, [])]],
5518 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto m]), core.Object]], 5657 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto m]), core.Object]],
5519 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott om, dart.bottom]), core.Object, core.Object]], 5658 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott om, dart.bottom]), core.Object, core.Object]],
5520 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {unGuar de: core.bool}], 5659 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {unGuar de: core.bool}],
5521 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da rt.bottom])], {unGuarde: core.bool}], 5660 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da rt.bottom])], {unGuarde: core.bool}],
5522 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [ dart.bottom, dart.bottom])], {unGuarde: core.bool}], 5661 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [ dart.bottom, dart.bottom])], {unGuarde: core.bool}],
5523 get: [core.Object, [core.Object]], 5662 get: [core.Object, [core.Object]],
5524 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], 5663 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]],
5525 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}], 5664 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}],
(...skipping 250 matching lines...) Expand 10 before | Expand all | Expand 10 after
5776 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5915 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5777 exports.CreateTimerHandler = CreateTimerHandler; 5916 exports.CreateTimerHandler = CreateTimerHandler;
5778 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5917 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5779 exports.PrintHandler = PrintHandler; 5918 exports.PrintHandler = PrintHandler;
5780 exports.ForkHandler = ForkHandler; 5919 exports.ForkHandler = ForkHandler;
5781 exports.ZoneSpecification = ZoneSpecification; 5920 exports.ZoneSpecification = ZoneSpecification;
5782 exports.ZoneDelegate = ZoneDelegate; 5921 exports.ZoneDelegate = ZoneDelegate;
5783 exports.Zone = Zone; 5922 exports.Zone = Zone;
5784 exports.runZoned = runZoned; 5923 exports.runZoned = runZoned;
5785 })(async, core, _internal, _js_helper, _isolate_helper, collection); 5924 })(async, core, _internal, _js_helper, _isolate_helper, collection);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698