| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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); |
| OLD | NEW |