| OLD | NEW |
| 1 var async; | 1 var async; |
| 2 (function(exports) { | 2 (function(exports) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic | 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic |
| 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
| 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| 7 return dart.dinvokef(errorHandler, error, stackTrace); | 7 return dart.dinvokef(errorHandler, error, stackTrace); |
| 8 } else { | 8 } else { |
| 9 return dart.dinvokef(errorHandler, error); | 9 return dart.dinvokef(errorHandler, error); |
| 10 } | 10 } |
| 11 } | 11 } |
| 12 // Function _registerErrorHandler: (Function, Zone) → Function | 12 // Function _registerErrorHandler: (Function, Zone) → Function |
| 13 function _registerErrorHandler(errorHandler, zone) { | 13 function _registerErrorHandler(errorHandler, zone) { |
| 14 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 14 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| 15 return zone.registerBinaryCallback(errorHandler); | 15 return zone.registerBinaryCallback(errorHandler); |
| 16 } else { | 16 } else { |
| 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.throw_("Unimp
lemented type (dynamic) → dynamic"))); | 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.throw_("Unimp
lemented type (dynamic) → dynamic"))); |
| 18 } | 18 } |
| 19 } | 19 } |
| 20 let _getBestStackTrace = Symbol('_getBestStackTrace'); | 20 let _getBestStackTrace = Symbol('_getBestStackTrace'); |
| 21 class AsyncError extends core.Object { | 21 class AsyncError extends core.Object { |
| 22 AsyncError(error, stackTrace) { | 22 AsyncError(error, stackTrace) { |
| 23 this.error = error; | 23 this.error = error; |
| 24 this.stackTrace = stackTrace; | 24 this.stackTrace = stackTrace; |
| 25 } | 25 } |
| 26 toString() { | 26 toString() { |
| 27 return dart.as(dart.dinvoke(this.error, 'toString'), core.String); | 27 return dart.as(dart.dinvoke(this.error, 'toString'), core.String); |
| 28 } | 28 } |
| 29 } | 29 } |
| 30 AsyncError[dart.implements] = [core.Error]; | 30 AsyncError[dart.implements] = () => [core.Error]; |
| 31 class _UncaughtAsyncError extends AsyncError { | 31 class _UncaughtAsyncError extends AsyncError { |
| 32 _UncaughtAsyncError(error, stackTrace) { | 32 _UncaughtAsyncError(error, stackTrace) { |
| 33 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta
ckTrace)); | 33 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta
ckTrace)); |
| 34 } | 34 } |
| 35 static [_getBestStackTrace](error, stackTrace) { | 35 static [_getBestStackTrace](error, stackTrace) { |
| 36 if (stackTrace != null) | 36 if (stackTrace != null) |
| 37 return stackTrace; | 37 return stackTrace; |
| 38 if (dart.is(error, core.Error)) { | 38 if (dart.is(error, core.Error)) { |
| 39 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); | 39 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); |
| 40 } | 40 } |
| (...skipping 1030 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1071 this[_onResume](); | 1071 this[_onResume](); |
| 1072 } | 1072 } |
| 1073 this[_state] = ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CA
LLBACK]); | 1073 this[_state] = ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CA
LLBACK]); |
| 1074 wasInputPaused = isInputPaused; | 1074 wasInputPaused = isInputPaused; |
| 1075 } | 1075 } |
| 1076 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) { | 1076 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) { |
| 1077 this[_pending].schedule(this); | 1077 this[_pending].schedule(this); |
| 1078 } | 1078 } |
| 1079 } | 1079 } |
| 1080 } | 1080 } |
| 1081 _BufferingStreamSubscription[dart.implements] = [StreamSubscription$(T), _Ev
entSink$(T), _EventDispatch$(T)]; | 1081 _BufferingStreamSubscription[dart.implements] = () => [StreamSubscription$(T
), _EventSink$(T), _EventDispatch$(T)]; |
| 1082 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; | 1082 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; |
| 1083 _BufferingStreamSubscription._STATE_CLOSED = 2; | 1083 _BufferingStreamSubscription._STATE_CLOSED = 2; |
| 1084 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; | 1084 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; |
| 1085 _BufferingStreamSubscription._STATE_CANCELED = 8; | 1085 _BufferingStreamSubscription._STATE_CANCELED = 8; |
| 1086 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; | 1086 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; |
| 1087 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; | 1087 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; |
| 1088 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; | 1088 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; |
| 1089 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; | 1089 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; |
| 1090 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; | 1090 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; |
| 1091 return _BufferingStreamSubscription; | 1091 return _BufferingStreamSubscription; |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1134 [_setRemoveAfterFiring]() { | 1134 [_setRemoveAfterFiring]() { |
| 1135 dart.assert(this[_isFiring]); | 1135 dart.assert(this[_isFiring]); |
| 1136 this[_eventState] = _BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING]; | 1136 this[_eventState] = _BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING]; |
| 1137 } | 1137 } |
| 1138 get [_removeAfterFiring]() { | 1138 get [_removeAfterFiring]() { |
| 1139 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption[_STATE_REMOVE_AFTER_FIRING])) != 0; | 1139 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption[_STATE_REMOVE_AFTER_FIRING])) != 0; |
| 1140 } | 1140 } |
| 1141 [_onPause]() {} | 1141 [_onPause]() {} |
| 1142 [_onResume]() {} | 1142 [_onResume]() {} |
| 1143 } | 1143 } |
| 1144 _BroadcastSubscription[dart.implements] = [_BroadcastSubscriptionLink]; | 1144 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink]
; |
| 1145 _BroadcastSubscription._STATE_EVENT_ID = 1; | 1145 _BroadcastSubscription._STATE_EVENT_ID = 1; |
| 1146 _BroadcastSubscription._STATE_FIRING = 2; | 1146 _BroadcastSubscription._STATE_FIRING = 2; |
| 1147 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; | 1147 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; |
| 1148 return _BroadcastSubscription; | 1148 return _BroadcastSubscription; |
| 1149 }); | 1149 }); |
| 1150 let _BroadcastSubscription = _BroadcastSubscription$(dart.dynamic); | 1150 let _BroadcastSubscription = _BroadcastSubscription$(dart.dynamic); |
| 1151 let _STATE_INITIAL = Symbol('_STATE_INITIAL'); | 1151 let _STATE_INITIAL = Symbol('_STATE_INITIAL'); |
| 1152 let _addStreamState = Symbol('_addStreamState'); | 1152 let _addStreamState = Symbol('_addStreamState'); |
| 1153 let _doneFuture = Symbol('_doneFuture'); | 1153 let _doneFuture = Symbol('_doneFuture'); |
| 1154 let _isEmpty = Symbol('_isEmpty'); | 1154 let _isEmpty = Symbol('_isEmpty'); |
| (...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1353 } | 1353 } |
| 1354 } | 1354 } |
| 1355 [_callOnCancel]() { | 1355 [_callOnCancel]() { |
| 1356 dart.assert(this[_isEmpty]); | 1356 dart.assert(this[_isEmpty]); |
| 1357 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo
mplete])) { | 1357 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo
mplete])) { |
| 1358 this[_doneFuture]._asyncComplete(null); | 1358 this[_doneFuture]._asyncComplete(null); |
| 1359 } | 1359 } |
| 1360 _runGuarded(this[_onCancel]); | 1360 _runGuarded(this[_onCancel]); |
| 1361 } | 1361 } |
| 1362 } | 1362 } |
| 1363 _BroadcastStreamController[dart.implements] = [StreamController$(T), _Stream
ControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _EventDispa
tch$(T)]; | 1363 _BroadcastStreamController[dart.implements] = () => [StreamController$(T), _
StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _Even
tDispatch$(T)]; |
| 1364 _BroadcastStreamController._STATE_INITIAL = 0; | 1364 _BroadcastStreamController._STATE_INITIAL = 0; |
| 1365 _BroadcastStreamController._STATE_EVENT_ID = 1; | 1365 _BroadcastStreamController._STATE_EVENT_ID = 1; |
| 1366 _BroadcastStreamController._STATE_FIRING = 2; | 1366 _BroadcastStreamController._STATE_FIRING = 2; |
| 1367 _BroadcastStreamController._STATE_CLOSED = 4; | 1367 _BroadcastStreamController._STATE_CLOSED = 4; |
| 1368 _BroadcastStreamController._STATE_ADDSTREAM = 8; | 1368 _BroadcastStreamController._STATE_ADDSTREAM = 8; |
| 1369 return _BroadcastStreamController; | 1369 return _BroadcastStreamController; |
| 1370 }); | 1370 }); |
| 1371 let _BroadcastStreamController = _BroadcastStreamController$(dart.dynamic); | 1371 let _BroadcastStreamController = _BroadcastStreamController$(dart.dynamic); |
| 1372 let _SyncBroadcastStreamController$ = dart.generic(function(T) { | 1372 let _SyncBroadcastStreamController$ = dart.generic(function(T) { |
| 1373 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T)
{ | 1373 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T)
{ |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1497 return result; | 1497 return result; |
| 1498 } | 1498 } |
| 1499 [_callOnCancel]() { | 1499 [_callOnCancel]() { |
| 1500 if (this[_hasPending]) { | 1500 if (this[_hasPending]) { |
| 1501 this[_pending].clear(); | 1501 this[_pending].clear(); |
| 1502 this[_pending] = null; | 1502 this[_pending] = null; |
| 1503 } | 1503 } |
| 1504 super._callOnCancel(); | 1504 super._callOnCancel(); |
| 1505 } | 1505 } |
| 1506 } | 1506 } |
| 1507 _AsBroadcastStreamController[dart.implements] = [_EventDispatch$(T)]; | 1507 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)]; |
| 1508 return _AsBroadcastStreamController; | 1508 return _AsBroadcastStreamController; |
| 1509 }); | 1509 }); |
| 1510 let _AsBroadcastStreamController = _AsBroadcastStreamController$(dart.dynamic)
; | 1510 let _AsBroadcastStreamController = _AsBroadcastStreamController$(dart.dynamic)
; |
| 1511 let _pauseCount = Symbol('_pauseCount'); | 1511 let _pauseCount = Symbol('_pauseCount'); |
| 1512 let _resume = Symbol('_resume'); | 1512 let _resume = Symbol('_resume'); |
| 1513 let _DoneSubscription$ = dart.generic(function(T) { | 1513 let _DoneSubscription$ = dart.generic(function(T) { |
| 1514 class _DoneSubscription extends core.Object { | 1514 class _DoneSubscription extends core.Object { |
| 1515 _DoneSubscription() { | 1515 _DoneSubscription() { |
| 1516 this[_pauseCount] = 0; | 1516 this[_pauseCount] = 0; |
| 1517 } | 1517 } |
| (...skipping 19 matching lines...) Expand all Loading... |
| 1537 } | 1537 } |
| 1538 get isPaused() { | 1538 get isPaused() { |
| 1539 return dart.notNull(this[_pauseCount]) > 0; | 1539 return dart.notNull(this[_pauseCount]) > 0; |
| 1540 } | 1540 } |
| 1541 asFuture(value) { | 1541 asFuture(value) { |
| 1542 if (value === void 0) | 1542 if (value === void 0) |
| 1543 value = null; | 1543 value = null; |
| 1544 return new _Future(); | 1544 return new _Future(); |
| 1545 } | 1545 } |
| 1546 } | 1546 } |
| 1547 _DoneSubscription[dart.implements] = [StreamSubscription$(T)]; | 1547 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
| 1548 return _DoneSubscription; | 1548 return _DoneSubscription; |
| 1549 }); | 1549 }); |
| 1550 let _DoneSubscription = _DoneSubscription$(dart.dynamic); | 1550 let _DoneSubscription = _DoneSubscription$(dart.dynamic); |
| 1551 class DeferredLibrary extends core.Object { | 1551 class DeferredLibrary extends core.Object { |
| 1552 DeferredLibrary(libraryName, opts) { | 1552 DeferredLibrary(libraryName, opts) { |
| 1553 let uri = opts && 'uri' in opts ? opts.uri : null; | 1553 let uri = opts && 'uri' in opts ? opts.uri : null; |
| 1554 this.libraryName = libraryName; | 1554 this.libraryName = libraryName; |
| 1555 this.uri = uri; | 1555 this.uri = uri; |
| 1556 } | 1556 } |
| 1557 load() { | 1557 load() { |
| 1558 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; | 1558 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; |
| 1559 } | 1559 } |
| 1560 } | 1560 } |
| 1561 let _s = Symbol('_s'); | 1561 let _s = Symbol('_s'); |
| 1562 class DeferredLoadException extends core.Object { | 1562 class DeferredLoadException extends core.Object { |
| 1563 DeferredLoadException(s$) { | 1563 DeferredLoadException(s$) { |
| 1564 this[_s] = s$; | 1564 this[_s] = s$; |
| 1565 } | 1565 } |
| 1566 toString() { | 1566 toString() { |
| 1567 return `DeferredLoadException: '${this[_s]}'`; | 1567 return `DeferredLoadException: '${this[_s]}'`; |
| 1568 } | 1568 } |
| 1569 } | 1569 } |
| 1570 DeferredLoadException[dart.implements] = [core.Exception]; | 1570 DeferredLoadException[dart.implements] = () => [core.Exception]; |
| 1571 let Future$ = dart.generic(function(T) { | 1571 let Future$ = dart.generic(function(T) { |
| 1572 class Future extends core.Object { | 1572 class Future extends core.Object { |
| 1573 Future(computation) { | 1573 Future(computation) { |
| 1574 let result = new _Future(); | 1574 let result = new _Future(); |
| 1575 Timer.run((() => { | 1575 Timer.run((() => { |
| 1576 try { | 1576 try { |
| 1577 result._complete(computation()); | 1577 result._complete(computation()); |
| 1578 } catch (e) { | 1578 } catch (e) { |
| 1579 let s = dart.stackTrace(e); | 1579 let s = dart.stackTrace(e); |
| 1580 _completeWithErrorCallback(result, e, s); | 1580 _completeWithErrorCallback(result, e, s); |
| (...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1742 } | 1742 } |
| 1743 toString() { | 1743 toString() { |
| 1744 let result = "TimeoutException"; | 1744 let result = "TimeoutException"; |
| 1745 if (this.duration != null) | 1745 if (this.duration != null) |
| 1746 result = `TimeoutException after ${this.duration}`; | 1746 result = `TimeoutException after ${this.duration}`; |
| 1747 if (this.message != null) | 1747 if (this.message != null) |
| 1748 result = `${result}: ${this.message}`; | 1748 result = `${result}: ${this.message}`; |
| 1749 return result; | 1749 return result; |
| 1750 } | 1750 } |
| 1751 } | 1751 } |
| 1752 TimeoutException[dart.implements] = [core.Exception]; | 1752 TimeoutException[dart.implements] = () => [core.Exception]; |
| 1753 let Completer$ = dart.generic(function(T) { | 1753 let Completer$ = dart.generic(function(T) { |
| 1754 class Completer extends core.Object { | 1754 class Completer extends core.Object { |
| 1755 Completer() { | 1755 Completer() { |
| 1756 return new _AsyncCompleter(); | 1756 return new _AsyncCompleter(); |
| 1757 } | 1757 } |
| 1758 sync() { | 1758 sync() { |
| 1759 return new _SyncCompleter(); | 1759 return new _SyncCompleter(); |
| 1760 } | 1760 } |
| 1761 } | 1761 } |
| 1762 dart.defineNamedConstructor(Completer, 'sync'); | 1762 dart.defineNamedConstructor(Completer, 'sync'); |
| (...skipping 28 matching lines...) Expand all Loading... |
| 1791 if (replacement != null) { | 1791 if (replacement != null) { |
| 1792 error = _nonNullError(replacement.error); | 1792 error = _nonNullError(replacement.error); |
| 1793 stackTrace = replacement.stackTrace; | 1793 stackTrace = replacement.stackTrace; |
| 1794 } | 1794 } |
| 1795 this[_completeError](error, stackTrace); | 1795 this[_completeError](error, stackTrace); |
| 1796 } | 1796 } |
| 1797 get isCompleted() { | 1797 get isCompleted() { |
| 1798 return !dart.notNull(this.future[_mayComplete]); | 1798 return !dart.notNull(this.future[_mayComplete]); |
| 1799 } | 1799 } |
| 1800 } | 1800 } |
| 1801 _Completer[dart.implements] = [Completer$(T)]; | 1801 _Completer[dart.implements] = () => [Completer$(T)]; |
| 1802 return _Completer; | 1802 return _Completer; |
| 1803 }); | 1803 }); |
| 1804 let _Completer = _Completer$(dart.dynamic); | 1804 let _Completer = _Completer$(dart.dynamic); |
| 1805 let _AsyncCompleter$ = dart.generic(function(T) { | 1805 let _AsyncCompleter$ = dart.generic(function(T) { |
| 1806 class _AsyncCompleter extends _Completer$(T) { | 1806 class _AsyncCompleter extends _Completer$(T) { |
| 1807 complete(value) { | 1807 complete(value) { |
| 1808 if (value === void 0) | 1808 if (value === void 0) |
| 1809 value = null; | 1809 value = null; |
| 1810 if (!dart.notNull(this.future[_mayComplete])) | 1810 if (!dart.notNull(this.future[_mayComplete])) |
| 1811 throw new core.StateError("Future already completed"); | 1811 throw new core.StateError("Future already completed"); |
| (...skipping 530 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2342 } | 2342 } |
| 2343 }).bind(this), {onError: ((e, s) => { | 2343 }).bind(this), {onError: ((e, s) => { |
| 2344 if (timer.isActive) { | 2344 if (timer.isActive) { |
| 2345 timer.cancel(); | 2345 timer.cancel(); |
| 2346 result._completeError(e, dart.as(s, core.StackTrace)); | 2346 result._completeError(e, dart.as(s, core.StackTrace)); |
| 2347 } | 2347 } |
| 2348 }).bind(this)}); | 2348 }).bind(this)}); |
| 2349 return result; | 2349 return result; |
| 2350 } | 2350 } |
| 2351 } | 2351 } |
| 2352 _Future[dart.implements] = [Future$(T)]; | 2352 _Future[dart.implements] = () => [Future$(T)]; |
| 2353 dart.defineNamedConstructor(_Future, 'immediate'); | 2353 dart.defineNamedConstructor(_Future, 'immediate'); |
| 2354 dart.defineNamedConstructor(_Future, 'immediateError'); | 2354 dart.defineNamedConstructor(_Future, 'immediateError'); |
| 2355 _Future._INCOMPLETE = 0; | 2355 _Future._INCOMPLETE = 0; |
| 2356 _Future._PENDING_COMPLETE = 1; | 2356 _Future._PENDING_COMPLETE = 1; |
| 2357 _Future._CHAINED = 2; | 2357 _Future._CHAINED = 2; |
| 2358 _Future._VALUE = 4; | 2358 _Future._VALUE = 4; |
| 2359 _Future._ERROR = 8; | 2359 _Future._ERROR = 8; |
| 2360 return _Future; | 2360 return _Future; |
| 2361 }); | 2361 }); |
| 2362 let _Future = _Future$(dart.dynamic); | 2362 let _Future = _Future$(dart.dynamic); |
| (...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2502 }); | 2502 }); |
| 2503 let StreamSubscription$ = dart.generic(function(T) { | 2503 let StreamSubscription$ = dart.generic(function(T) { |
| 2504 class StreamSubscription extends core.Object { | 2504 class StreamSubscription extends core.Object { |
| 2505 } | 2505 } |
| 2506 return StreamSubscription; | 2506 return StreamSubscription; |
| 2507 }); | 2507 }); |
| 2508 let StreamSubscription = StreamSubscription$(dart.dynamic); | 2508 let StreamSubscription = StreamSubscription$(dart.dynamic); |
| 2509 let EventSink$ = dart.generic(function(T) { | 2509 let EventSink$ = dart.generic(function(T) { |
| 2510 class EventSink extends core.Object { | 2510 class EventSink extends core.Object { |
| 2511 } | 2511 } |
| 2512 EventSink[dart.implements] = [core.Sink$(T)]; | 2512 EventSink[dart.implements] = () => [core.Sink$(T)]; |
| 2513 return EventSink; | 2513 return EventSink; |
| 2514 }); | 2514 }); |
| 2515 let EventSink = EventSink$(dart.dynamic); | 2515 let EventSink = EventSink$(dart.dynamic); |
| 2516 let _stream = Symbol('_stream'); | 2516 let _stream = Symbol('_stream'); |
| 2517 let StreamView$ = dart.generic(function(T) { | 2517 let StreamView$ = dart.generic(function(T) { |
| 2518 class StreamView extends Stream$(T) { | 2518 class StreamView extends Stream$(T) { |
| 2519 StreamView(stream$) { | 2519 StreamView(stream$) { |
| 2520 this[_stream] = stream$; | 2520 this[_stream] = stream$; |
| 2521 super.Stream(); | 2521 super.Stream(); |
| 2522 } | 2522 } |
| (...skipping 17 matching lines...) Expand all Loading... |
| 2540 let StreamView = StreamView$(dart.dynamic); | 2540 let StreamView = StreamView$(dart.dynamic); |
| 2541 let StreamConsumer$ = dart.generic(function(S) { | 2541 let StreamConsumer$ = dart.generic(function(S) { |
| 2542 class StreamConsumer extends core.Object { | 2542 class StreamConsumer extends core.Object { |
| 2543 } | 2543 } |
| 2544 return StreamConsumer; | 2544 return StreamConsumer; |
| 2545 }); | 2545 }); |
| 2546 let StreamConsumer = StreamConsumer$(dart.dynamic); | 2546 let StreamConsumer = StreamConsumer$(dart.dynamic); |
| 2547 let StreamSink$ = dart.generic(function(S) { | 2547 let StreamSink$ = dart.generic(function(S) { |
| 2548 class StreamSink extends core.Object { | 2548 class StreamSink extends core.Object { |
| 2549 } | 2549 } |
| 2550 StreamSink[dart.implements] = [StreamConsumer$(S), EventSink$(S)]; | 2550 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)]; |
| 2551 return StreamSink; | 2551 return StreamSink; |
| 2552 }); | 2552 }); |
| 2553 let StreamSink = StreamSink$(dart.dynamic); | 2553 let StreamSink = StreamSink$(dart.dynamic); |
| 2554 let StreamTransformer$ = dart.generic(function(S, T) { | 2554 let StreamTransformer$ = dart.generic(function(S, T) { |
| 2555 class StreamTransformer extends core.Object { | 2555 class StreamTransformer extends core.Object { |
| 2556 StreamTransformer(transformer) { | 2556 StreamTransformer(transformer) { |
| 2557 return new _StreamSubscriptionTransformer(transformer); | 2557 return new _StreamSubscriptionTransformer(transformer); |
| 2558 } | 2558 } |
| 2559 fromHandlers(opts) { | 2559 fromHandlers(opts) { |
| 2560 return new _StreamHandlerTransformer(opts); | 2560 return new _StreamHandlerTransformer(opts); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 2583 } | 2583 } |
| 2584 addError(error, stackTrace) { | 2584 addError(error, stackTrace) { |
| 2585 if (stackTrace === void 0) | 2585 if (stackTrace === void 0) |
| 2586 stackTrace = null; | 2586 stackTrace = null; |
| 2587 this[_sink].addError(error, stackTrace); | 2587 this[_sink].addError(error, stackTrace); |
| 2588 } | 2588 } |
| 2589 close() { | 2589 close() { |
| 2590 this[_sink].close(); | 2590 this[_sink].close(); |
| 2591 } | 2591 } |
| 2592 } | 2592 } |
| 2593 _ControllerEventSinkWrapper[dart.implements] = [EventSink$(T)]; | 2593 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
| 2594 return _ControllerEventSinkWrapper; | 2594 return _ControllerEventSinkWrapper; |
| 2595 }); | 2595 }); |
| 2596 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic); | 2596 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic); |
| 2597 let StreamController$ = dart.generic(function(T) { | 2597 let StreamController$ = dart.generic(function(T) { |
| 2598 class StreamController extends core.Object { | 2598 class StreamController extends core.Object { |
| 2599 StreamController(opts) { | 2599 StreamController(opts) { |
| 2600 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2600 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 2601 let onPause = opts && 'onPause' in opts ? opts.onPause : null; | 2601 let onPause = opts && 'onPause' in opts ? opts.onPause : null; |
| 2602 let onResume = opts && 'onResume' in opts ? opts.onResume : null; | 2602 let onResume = opts && 'onResume' in opts ? opts.onResume : null; |
| 2603 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2603 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 2604 let sync = opts && 'sync' in opts ? opts.sync : false; | 2604 let sync = opts && 'sync' in opts ? opts.sync : false; |
| 2605 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d
art.notNull(onResume == null) && dart.notNull(onCancel == null)) { | 2605 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d
art.notNull(onResume == null) && dart.notNull(onCancel == null)) { |
| 2606 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC
allbackAsyncStreamController(), StreamController$(T)); | 2606 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC
allbackAsyncStreamController(), StreamController$(T)); |
| 2607 } | 2607 } |
| 2608 return sync ? new _SyncStreamController(onListen, onPause, onResume, onC
ancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel); | 2608 return sync ? new _SyncStreamController(onListen, onPause, onResume, onC
ancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel); |
| 2609 } | 2609 } |
| 2610 broadcast(opts) { | 2610 broadcast(opts) { |
| 2611 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2611 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 2612 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2612 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 2613 let sync = opts && 'sync' in opts ? opts.sync : false; | 2613 let sync = opts && 'sync' in opts ? opts.sync : false; |
| 2614 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n
ew _AsyncBroadcastStreamController(onListen, onCancel); | 2614 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n
ew _AsyncBroadcastStreamController(onListen, onCancel); |
| 2615 } | 2615 } |
| 2616 } | 2616 } |
| 2617 StreamController[dart.implements] = [StreamSink$(T)]; | 2617 StreamController[dart.implements] = () => [StreamSink$(T)]; |
| 2618 dart.defineNamedConstructor(StreamController, 'broadcast'); | 2618 dart.defineNamedConstructor(StreamController, 'broadcast'); |
| 2619 return StreamController; | 2619 return StreamController; |
| 2620 }); | 2620 }); |
| 2621 let StreamController = StreamController$(dart.dynamic); | 2621 let StreamController = StreamController$(dart.dynamic); |
| 2622 let _StreamControllerLifecycle$ = dart.generic(function(T) { | 2622 let _StreamControllerLifecycle$ = dart.generic(function(T) { |
| 2623 class _StreamControllerLifecycle extends core.Object { | 2623 class _StreamControllerLifecycle extends core.Object { |
| 2624 [_recordPause](subscription) {} | 2624 [_recordPause](subscription) {} |
| 2625 [_recordResume](subscription) {} | 2625 [_recordResume](subscription) {} |
| 2626 [_recordCancel](subscription) { | 2626 [_recordCancel](subscription) { |
| 2627 return null; | 2627 return null; |
| (...skipping 222 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2850 _runGuarded(this[_onPause]); | 2850 _runGuarded(this[_onPause]); |
| 2851 } | 2851 } |
| 2852 [_recordResume](subscription) { | 2852 [_recordResume](subscription) { |
| 2853 if (this[_isAddingStream]) { | 2853 if (this[_isAddingStream]) { |
| 2854 let addState = dart.as(this[_varData], _StreamControllerAddStreamState
); | 2854 let addState = dart.as(this[_varData], _StreamControllerAddStreamState
); |
| 2855 addState.resume(); | 2855 addState.resume(); |
| 2856 } | 2856 } |
| 2857 _runGuarded(this[_onResume]); | 2857 _runGuarded(this[_onResume]); |
| 2858 } | 2858 } |
| 2859 } | 2859 } |
| 2860 _StreamController[dart.implements] = [StreamController$(T), _StreamControlle
rLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; | 2860 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon
trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; |
| 2861 _StreamController._STATE_INITIAL = 0; | 2861 _StreamController._STATE_INITIAL = 0; |
| 2862 _StreamController._STATE_SUBSCRIBED = 1; | 2862 _StreamController._STATE_SUBSCRIBED = 1; |
| 2863 _StreamController._STATE_CANCELED = 2; | 2863 _StreamController._STATE_CANCELED = 2; |
| 2864 _StreamController._STATE_SUBSCRIPTION_MASK = 3; | 2864 _StreamController._STATE_SUBSCRIPTION_MASK = 3; |
| 2865 _StreamController._STATE_CLOSED = 4; | 2865 _StreamController._STATE_CLOSED = 4; |
| 2866 _StreamController._STATE_ADDSTREAM = 8; | 2866 _StreamController._STATE_ADDSTREAM = 8; |
| 2867 return _StreamController; | 2867 return _StreamController; |
| 2868 }); | 2868 }); |
| 2869 let _StreamController = _StreamController$(dart.dynamic); | 2869 let _StreamController = _StreamController$(dart.dynamic); |
| 2870 let _SyncStreamControllerDispatch$ = dart.generic(function(T) { | 2870 let _SyncStreamControllerDispatch$ = dart.generic(function(T) { |
| 2871 class _SyncStreamControllerDispatch extends core.Object { | 2871 class _SyncStreamControllerDispatch extends core.Object { |
| 2872 [_sendData](data) { | 2872 [_sendData](data) { |
| 2873 this[_subscription]._add(data); | 2873 this[_subscription]._add(data); |
| 2874 } | 2874 } |
| 2875 [_sendError](error, stackTrace) { | 2875 [_sendError](error, stackTrace) { |
| 2876 this[_subscription]._addError(error, stackTrace); | 2876 this[_subscription]._addError(error, stackTrace); |
| 2877 } | 2877 } |
| 2878 [_sendDone]() { | 2878 [_sendDone]() { |
| 2879 this[_subscription]._close(); | 2879 this[_subscription]._close(); |
| 2880 } | 2880 } |
| 2881 } | 2881 } |
| 2882 _SyncStreamControllerDispatch[dart.implements] = [_StreamController$(T)]; | 2882 _SyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T
)]; |
| 2883 return _SyncStreamControllerDispatch; | 2883 return _SyncStreamControllerDispatch; |
| 2884 }); | 2884 }); |
| 2885 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dart.dynami
c); | 2885 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dart.dynami
c); |
| 2886 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { | 2886 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { |
| 2887 class _AsyncStreamControllerDispatch extends core.Object { | 2887 class _AsyncStreamControllerDispatch extends core.Object { |
| 2888 [_sendData](data) { | 2888 [_sendData](data) { |
| 2889 this[_subscription]._addPending(new _DelayedData(data)); | 2889 this[_subscription]._addPending(new _DelayedData(data)); |
| 2890 } | 2890 } |
| 2891 [_sendError](error, stackTrace) { | 2891 [_sendError](error, stackTrace) { |
| 2892 this[_subscription]._addPending(new _DelayedError(error, stackTrace)); | 2892 this[_subscription]._addPending(new _DelayedError(error, stackTrace)); |
| 2893 } | 2893 } |
| 2894 [_sendDone]() { | 2894 [_sendDone]() { |
| 2895 this[_subscription]._addPending(new _DelayedDone()); | 2895 this[_subscription]._addPending(new _DelayedDone()); |
| 2896 } | 2896 } |
| 2897 } | 2897 } |
| 2898 _AsyncStreamControllerDispatch[dart.implements] = [_StreamController$(T)]; | 2898 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(
T)]; |
| 2899 return _AsyncStreamControllerDispatch; | 2899 return _AsyncStreamControllerDispatch; |
| 2900 }); | 2900 }); |
| 2901 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dart.dyna
mic); | 2901 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dart.dyna
mic); |
| 2902 let _AsyncStreamController$ = dart.generic(function(T) { | 2902 let _AsyncStreamController$ = dart.generic(function(T) { |
| 2903 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { | 2903 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { |
| 2904 _AsyncStreamController(onListen$, onPause$, onResume$, onCancel$) { | 2904 _AsyncStreamController(onListen$, onPause$, onResume$, onCancel$) { |
| 2905 this[_onListen] = onListen$; | 2905 this[_onListen] = onListen$; |
| 2906 this[_onPause] = onPause$; | 2906 this[_onPause] = onPause$; |
| 2907 this[_onResume] = onResume$; | 2907 this[_onResume] = onResume$; |
| 2908 this[_onCancel] = onCancel$; | 2908 this[_onCancel] = onCancel$; |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2976 return this[_target].close(); | 2976 return this[_target].close(); |
| 2977 } | 2977 } |
| 2978 addStream(source, opts) { | 2978 addStream(source, opts) { |
| 2979 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: true; | 2979 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: true; |
| 2980 return this[_target].addStream(source, {cancelOnError: cancelOnError}); | 2980 return this[_target].addStream(source, {cancelOnError: cancelOnError}); |
| 2981 } | 2981 } |
| 2982 get done() { | 2982 get done() { |
| 2983 return this[_target].done; | 2983 return this[_target].done; |
| 2984 } | 2984 } |
| 2985 } | 2985 } |
| 2986 _StreamSinkWrapper[dart.implements] = [StreamSink$(T)]; | 2986 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)]; |
| 2987 return _StreamSinkWrapper; | 2987 return _StreamSinkWrapper; |
| 2988 }); | 2988 }); |
| 2989 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic); | 2989 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic); |
| 2990 let _AddStreamState$ = dart.generic(function(T) { | 2990 let _AddStreamState$ = dart.generic(function(T) { |
| 2991 class _AddStreamState extends core.Object { | 2991 class _AddStreamState extends core.Object { |
| 2992 _AddStreamState(controller, source, cancelOnError) { | 2992 _AddStreamState(controller, source, cancelOnError) { |
| 2993 this.addStreamFuture = new _Future(); | 2993 this.addStreamFuture = new _Future(); |
| 2994 this.addSubscription = source.listen(controller[_add], {onError: dart.as
(cancelOnError ? _AddStreamState.makeErrorHandler(controller) : controller[_addE
rror], core.Function), onDone: controller[_close], cancelOnError: cancelOnError}
); | 2994 this.addSubscription = source.listen(controller[_add], {onError: dart.as
(cancelOnError ? _AddStreamState.makeErrorHandler(controller) : controller[_addE
rror], core.Function), onDone: controller[_close], cancelOnError: cancelOnError}
); |
| 2995 } | 2995 } |
| 2996 static makeErrorHandler(controller) { | 2996 static makeErrorHandler(controller) { |
| (...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3193 perform(dispatch) { | 3193 perform(dispatch) { |
| 3194 dispatch._sendDone(); | 3194 dispatch._sendDone(); |
| 3195 } | 3195 } |
| 3196 get next() { | 3196 get next() { |
| 3197 return null; | 3197 return null; |
| 3198 } | 3198 } |
| 3199 set next(_) { | 3199 set next(_) { |
| 3200 throw new core.StateError("No events after a done."); | 3200 throw new core.StateError("No events after a done."); |
| 3201 } | 3201 } |
| 3202 } | 3202 } |
| 3203 _DelayedDone[dart.implements] = [_DelayedEvent]; | 3203 _DelayedDone[dart.implements] = () => [_DelayedEvent]; |
| 3204 class _StreamImplEvents extends _PendingEvents { | 3204 class _StreamImplEvents extends _PendingEvents { |
| 3205 _StreamImplEvents() { | 3205 _StreamImplEvents() { |
| 3206 this.firstPendingEvent = null; | 3206 this.firstPendingEvent = null; |
| 3207 this.lastPendingEvent = null; | 3207 this.lastPendingEvent = null; |
| 3208 super._PendingEvents(); | 3208 super._PendingEvents(); |
| 3209 } | 3209 } |
| 3210 get isEmpty() { | 3210 get isEmpty() { |
| 3211 return this.lastPendingEvent == null; | 3211 return this.lastPendingEvent == null; |
| 3212 } | 3212 } |
| 3213 add(event) { | 3213 add(event) { |
| (...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3315 } | 3315 } |
| 3316 [_sendDone]() { | 3316 [_sendDone]() { |
| 3317 this[_state] = ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]); | 3317 this[_state] = ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]); |
| 3318 if (this.isPaused) | 3318 if (this.isPaused) |
| 3319 return; | 3319 return; |
| 3320 this[_state] = _DoneStreamSubscription[_DONE_SENT]; | 3320 this[_state] = _DoneStreamSubscription[_DONE_SENT]; |
| 3321 if (this[_onDone] != null) | 3321 if (this[_onDone] != null) |
| 3322 this[_zone].runGuarded(this[_onDone]); | 3322 this[_zone].runGuarded(this[_onDone]); |
| 3323 } | 3323 } |
| 3324 } | 3324 } |
| 3325 _DoneStreamSubscription[dart.implements] = [StreamSubscription$(T)]; | 3325 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
| 3326 _DoneStreamSubscription._DONE_SENT = 1; | 3326 _DoneStreamSubscription._DONE_SENT = 1; |
| 3327 _DoneStreamSubscription._SCHEDULED = 2; | 3327 _DoneStreamSubscription._SCHEDULED = 2; |
| 3328 _DoneStreamSubscription._PAUSED = 4; | 3328 _DoneStreamSubscription._PAUSED = 4; |
| 3329 return _DoneStreamSubscription; | 3329 return _DoneStreamSubscription; |
| 3330 }); | 3330 }); |
| 3331 let _DoneStreamSubscription = _DoneStreamSubscription$(dart.dynamic); | 3331 let _DoneStreamSubscription = _DoneStreamSubscription$(dart.dynamic); |
| 3332 let _source = Symbol('_source'); | 3332 let _source = Symbol('_source'); |
| 3333 let _onListenHandler = Symbol('_onListenHandler'); | 3333 let _onListenHandler = Symbol('_onListenHandler'); |
| 3334 let _onCancelHandler = Symbol('_onCancelHandler'); | 3334 let _onCancelHandler = Symbol('_onCancelHandler'); |
| 3335 let _cancelSubscription = Symbol('_cancelSubscription'); | 3335 let _cancelSubscription = Symbol('_cancelSubscription'); |
| (...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3436 } | 3436 } |
| 3437 get isPaused() { | 3437 get isPaused() { |
| 3438 return this[_stream][_isSubscriptionPaused]; | 3438 return this[_stream][_isSubscriptionPaused]; |
| 3439 } | 3439 } |
| 3440 asFuture(futureValue) { | 3440 asFuture(futureValue) { |
| 3441 if (futureValue === void 0) | 3441 if (futureValue === void 0) |
| 3442 futureValue = null; | 3442 futureValue = null; |
| 3443 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); | 3443 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); |
| 3444 } | 3444 } |
| 3445 } | 3445 } |
| 3446 _BroadcastSubscriptionWrapper[dart.implements] = [StreamSubscription$(T)]; | 3446 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; |
| 3447 return _BroadcastSubscriptionWrapper; | 3447 return _BroadcastSubscriptionWrapper; |
| 3448 }); | 3448 }); |
| 3449 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dart.dynami
c); | 3449 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dart.dynami
c); |
| 3450 let _current = Symbol('_current'); | 3450 let _current = Symbol('_current'); |
| 3451 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); | 3451 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); |
| 3452 let _STATE_FOUND = Symbol('_STATE_FOUND'); | 3452 let _STATE_FOUND = Symbol('_STATE_FOUND'); |
| 3453 let _STATE_DONE = Symbol('_STATE_DONE'); | 3453 let _STATE_DONE = Symbol('_STATE_DONE'); |
| 3454 let _STATE_MOVING = Symbol('_STATE_MOVING'); | 3454 let _STATE_MOVING = Symbol('_STATE_MOVING'); |
| 3455 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); | 3455 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); |
| 3456 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); | 3456 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); |
| (...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3555 let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool)); | 3555 let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool)); |
| 3556 this[_clear](); | 3556 this[_clear](); |
| 3557 hasNext._complete(false); | 3557 hasNext._complete(false); |
| 3558 return; | 3558 return; |
| 3559 } | 3559 } |
| 3560 this[_subscription].pause(); | 3560 this[_subscription].pause(); |
| 3561 this[_futureOrPrefetch] = null; | 3561 this[_futureOrPrefetch] = null; |
| 3562 this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE]; | 3562 this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE]; |
| 3563 } | 3563 } |
| 3564 } | 3564 } |
| 3565 _StreamIteratorImpl[dart.implements] = [StreamIterator$(T)]; | 3565 _StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)]; |
| 3566 _StreamIteratorImpl._STATE_FOUND = 0; | 3566 _StreamIteratorImpl._STATE_FOUND = 0; |
| 3567 _StreamIteratorImpl._STATE_DONE = 1; | 3567 _StreamIteratorImpl._STATE_DONE = 1; |
| 3568 _StreamIteratorImpl._STATE_MOVING = 2; | 3568 _StreamIteratorImpl._STATE_MOVING = 2; |
| 3569 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 3569 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
| 3570 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 3570 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
| 3571 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 3571 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
| 3572 return _StreamIteratorImpl; | 3572 return _StreamIteratorImpl; |
| 3573 }); | 3573 }); |
| 3574 let _StreamIteratorImpl = _StreamIteratorImpl$(dart.dynamic); | 3574 let _StreamIteratorImpl = _StreamIteratorImpl$(dart.dynamic); |
| 3575 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT
race) → dynamic) → dynamic | 3575 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT
race) → dynamic) → dynamic |
| (...skipping 401 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3977 } | 3977 } |
| 3978 addError(error, stackTrace) { | 3978 addError(error, stackTrace) { |
| 3979 if (stackTrace === void 0) | 3979 if (stackTrace === void 0) |
| 3980 stackTrace = null; | 3980 stackTrace = null; |
| 3981 this[_sink]._addError(error, stackTrace); | 3981 this[_sink]._addError(error, stackTrace); |
| 3982 } | 3982 } |
| 3983 close() { | 3983 close() { |
| 3984 this[_sink]._close(); | 3984 this[_sink]._close(); |
| 3985 } | 3985 } |
| 3986 } | 3986 } |
| 3987 _EventSinkWrapper[dart.implements] = [EventSink$(T)]; | 3987 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
| 3988 return _EventSinkWrapper; | 3988 return _EventSinkWrapper; |
| 3989 }); | 3989 }); |
| 3990 let _EventSinkWrapper = _EventSinkWrapper$(dart.dynamic); | 3990 let _EventSinkWrapper = _EventSinkWrapper$(dart.dynamic); |
| 3991 let _transformerSink = Symbol('_transformerSink'); | 3991 let _transformerSink = Symbol('_transformerSink'); |
| 3992 let _isSubscribed = Symbol('_isSubscribed'); | 3992 let _isSubscribed = Symbol('_isSubscribed'); |
| 3993 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { | 3993 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { |
| 3994 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio
n$(T) { | 3994 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio
n$(T) { |
| 3995 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone
, cancelOnError) { | 3995 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone
, cancelOnError) { |
| 3996 this[_transformerSink] = null; | 3996 this[_transformerSink] = null; |
| 3997 this[_subscription] = null; | 3997 this[_subscription] = null; |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4078 let _sinkMapper = Symbol('_sinkMapper'); | 4078 let _sinkMapper = Symbol('_sinkMapper'); |
| 4079 let _StreamSinkTransformer$ = dart.generic(function(S, T) { | 4079 let _StreamSinkTransformer$ = dart.generic(function(S, T) { |
| 4080 class _StreamSinkTransformer extends core.Object { | 4080 class _StreamSinkTransformer extends core.Object { |
| 4081 _StreamSinkTransformer(sinkMapper) { | 4081 _StreamSinkTransformer(sinkMapper) { |
| 4082 this[_sinkMapper] = sinkMapper; | 4082 this[_sinkMapper] = sinkMapper; |
| 4083 } | 4083 } |
| 4084 bind(stream) { | 4084 bind(stream) { |
| 4085 return new _BoundSinkStream(stream, this[_sinkMapper]); | 4085 return new _BoundSinkStream(stream, this[_sinkMapper]); |
| 4086 } | 4086 } |
| 4087 } | 4087 } |
| 4088 _StreamSinkTransformer[dart.implements] = [StreamTransformer$(S, T)]; | 4088 _StreamSinkTransformer[dart.implements] = () => [StreamTransformer$(S, T)]; |
| 4089 return _StreamSinkTransformer; | 4089 return _StreamSinkTransformer; |
| 4090 }); | 4090 }); |
| 4091 let _StreamSinkTransformer = _StreamSinkTransformer$(dart.dynamic, dart.dynami
c); | 4091 let _StreamSinkTransformer = _StreamSinkTransformer$(dart.dynamic, dart.dynami
c); |
| 4092 let _BoundSinkStream$ = dart.generic(function(S, T) { | 4092 let _BoundSinkStream$ = dart.generic(function(S, T) { |
| 4093 class _BoundSinkStream extends Stream$(T) { | 4093 class _BoundSinkStream extends Stream$(T) { |
| 4094 get isBroadcast() { | 4094 get isBroadcast() { |
| 4095 return this[_stream].isBroadcast; | 4095 return this[_stream].isBroadcast; |
| 4096 } | 4096 } |
| 4097 _BoundSinkStream(stream$, sinkMapper) { | 4097 _BoundSinkStream(stream$, sinkMapper) { |
| 4098 this[_stream] = stream$; | 4098 this[_stream] = stream$; |
| (...skipping 25 matching lines...) Expand all Loading... |
| 4124 } | 4124 } |
| 4125 addError(error, stackTrace) { | 4125 addError(error, stackTrace) { |
| 4126 if (stackTrace === void 0) | 4126 if (stackTrace === void 0) |
| 4127 stackTrace = null; | 4127 stackTrace = null; |
| 4128 return this[_handleError](error, stackTrace, this[_sink]); | 4128 return this[_handleError](error, stackTrace, this[_sink]); |
| 4129 } | 4129 } |
| 4130 close() { | 4130 close() { |
| 4131 return this[_handleDone](this[_sink]); | 4131 return this[_handleDone](this[_sink]); |
| 4132 } | 4132 } |
| 4133 } | 4133 } |
| 4134 _HandlerEventSink[dart.implements] = [EventSink$(S)]; | 4134 _HandlerEventSink[dart.implements] = () => [EventSink$(S)]; |
| 4135 return _HandlerEventSink; | 4135 return _HandlerEventSink; |
| 4136 }); | 4136 }); |
| 4137 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic); | 4137 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic); |
| 4138 let _defaultHandleData = Symbol('_defaultHandleData'); | 4138 let _defaultHandleData = Symbol('_defaultHandleData'); |
| 4139 let _defaultHandleError = Symbol('_defaultHandleError'); | 4139 let _defaultHandleError = Symbol('_defaultHandleError'); |
| 4140 let _defaultHandleDone = Symbol('_defaultHandleDone'); | 4140 let _defaultHandleDone = Symbol('_defaultHandleDone'); |
| 4141 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { | 4141 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { |
| 4142 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { | 4142 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { |
| 4143 _StreamHandlerTransformer(opts) { | 4143 _StreamHandlerTransformer(opts) { |
| 4144 let handleData = opts && 'handleData' in opts ? opts.handleData : null; | 4144 let handleData = opts && 'handleData' in opts ? opts.handleData : null; |
| (...skipping 28 matching lines...) Expand all Loading... |
| 4173 let _transformer = Symbol('_transformer'); | 4173 let _transformer = Symbol('_transformer'); |
| 4174 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { | 4174 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { |
| 4175 class _StreamSubscriptionTransformer extends core.Object { | 4175 class _StreamSubscriptionTransformer extends core.Object { |
| 4176 _StreamSubscriptionTransformer(transformer$) { | 4176 _StreamSubscriptionTransformer(transformer$) { |
| 4177 this[_transformer] = transformer$; | 4177 this[_transformer] = transformer$; |
| 4178 } | 4178 } |
| 4179 bind(stream) { | 4179 bind(stream) { |
| 4180 return new _BoundSubscriptionStream(stream, this[_transformer]); | 4180 return new _BoundSubscriptionStream(stream, this[_transformer]); |
| 4181 } | 4181 } |
| 4182 } | 4182 } |
| 4183 _StreamSubscriptionTransformer[dart.implements] = [StreamTransformer$(S, T)]
; | 4183 _StreamSubscriptionTransformer[dart.implements] = () => [StreamTransformer$(
S, T)]; |
| 4184 return _StreamSubscriptionTransformer; | 4184 return _StreamSubscriptionTransformer; |
| 4185 }); | 4185 }); |
| 4186 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna
mic, dart.dynamic); | 4186 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna
mic, dart.dynamic); |
| 4187 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { | 4187 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { |
| 4188 class _BoundSubscriptionStream extends Stream$(T) { | 4188 class _BoundSubscriptionStream extends Stream$(T) { |
| 4189 _BoundSubscriptionStream(stream$, transformer$) { | 4189 _BoundSubscriptionStream(stream$, transformer$) { |
| 4190 this[_stream] = stream$; | 4190 this[_stream] = stream$; |
| 4191 this[_transformer] = transformer$; | 4191 this[_transformer] = transformer$; |
| 4192 super.Stream(); | 4192 super.Stream(); |
| 4193 } | 4193 } |
| (...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4289 this.registerUnaryCallback = registerUnaryCallback; | 4289 this.registerUnaryCallback = registerUnaryCallback; |
| 4290 this.registerBinaryCallback = registerBinaryCallback; | 4290 this.registerBinaryCallback = registerBinaryCallback; |
| 4291 this.errorCallback = errorCallback; | 4291 this.errorCallback = errorCallback; |
| 4292 this.scheduleMicrotask = scheduleMicrotask; | 4292 this.scheduleMicrotask = scheduleMicrotask; |
| 4293 this.createTimer = createTimer; | 4293 this.createTimer = createTimer; |
| 4294 this.createPeriodicTimer = createPeriodicTimer; | 4294 this.createPeriodicTimer = createPeriodicTimer; |
| 4295 this.print = print; | 4295 this.print = print; |
| 4296 this.fork = fork; | 4296 this.fork = fork; |
| 4297 } | 4297 } |
| 4298 } | 4298 } |
| 4299 _ZoneSpecification[dart.implements] = [ZoneSpecification]; | 4299 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
| 4300 class ZoneDelegate extends core.Object { | 4300 class ZoneDelegate extends core.Object { |
| 4301 } | 4301 } |
| 4302 let _$ = Symbol('_'); | 4302 let _$ = Symbol('_'); |
| 4303 let _enter = Symbol('_enter'); | 4303 let _enter = Symbol('_enter'); |
| 4304 let _leave = Symbol('_leave'); | 4304 let _leave = Symbol('_leave'); |
| 4305 class Zone extends core.Object { | 4305 class Zone extends core.Object { |
| 4306 [_$]() { | 4306 [_$]() { |
| 4307 } | 4307 } |
| 4308 static get current() { | 4308 static get current() { |
| 4309 return Zone[_current]; | 4309 return Zone[_current]; |
| (...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4407 let implementation = this[_delegationTarget][_print]; | 4407 let implementation = this[_delegationTarget][_print]; |
| 4408 let implZone = implementation.zone; | 4408 let implZone = implementation.zone; |
| 4409 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone)
, zone, line); | 4409 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone)
, zone, line); |
| 4410 } | 4410 } |
| 4411 fork(zone, specification, zoneValues) { | 4411 fork(zone, specification, zoneValues) { |
| 4412 let implementation = this[_delegationTarget][_fork]; | 4412 let implementation = this[_delegationTarget][_fork]; |
| 4413 let implZone = implementation.zone; | 4413 let implZone = implementation.zone; |
| 4414 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, specification, zoneValues), Zone); | 4414 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel
egate(implZone), zone, specification, zoneValues), Zone); |
| 4415 } | 4415 } |
| 4416 } | 4416 } |
| 4417 _ZoneDelegate[dart.implements] = [ZoneDelegate]; | 4417 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; |
| 4418 class _Zone extends core.Object { | 4418 class _Zone extends core.Object { |
| 4419 _Zone() { | 4419 _Zone() { |
| 4420 } | 4420 } |
| 4421 inSameErrorZone(otherZone) { | 4421 inSameErrorZone(otherZone) { |
| 4422 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); | 4422 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.
identical(this.errorZone, otherZone.errorZone)); |
| 4423 } | 4423 } |
| 4424 } | 4424 } |
| 4425 _Zone[dart.implements] = [Zone]; | 4425 _Zone[dart.implements] = () => [Zone]; |
| 4426 let _delegateCache = Symbol('_delegateCache'); | 4426 let _delegateCache = Symbol('_delegateCache'); |
| 4427 let _map = Symbol('_map'); | 4427 let _map = Symbol('_map'); |
| 4428 class _CustomZone extends _Zone { | 4428 class _CustomZone extends _Zone { |
| 4429 get [_delegate]() { | 4429 get [_delegate]() { |
| 4430 if (this[_delegateCache] != null) | 4430 if (this[_delegateCache] != null) |
| 4431 return this[_delegateCache]; | 4431 return this[_delegateCache]; |
| 4432 this[_delegateCache] = new _ZoneDelegate(this); | 4432 this[_delegateCache] = new _ZoneDelegate(this); |
| 4433 return this[_delegateCache]; | 4433 return this[_delegateCache]; |
| 4434 } | 4434 } |
| 4435 _CustomZone(parent, specification, map) { | 4435 _CustomZone(parent, specification, map) { |
| (...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4758 get createPeriodicTimer() { | 4758 get createPeriodicTimer() { |
| 4759 return _rootCreatePeriodicTimer; | 4759 return _rootCreatePeriodicTimer; |
| 4760 } | 4760 } |
| 4761 get print() { | 4761 get print() { |
| 4762 return _rootPrint; | 4762 return _rootPrint; |
| 4763 } | 4763 } |
| 4764 get fork() { | 4764 get fork() { |
| 4765 return _rootFork; | 4765 return _rootFork; |
| 4766 } | 4766 } |
| 4767 } | 4767 } |
| 4768 _RootZoneSpecification[dart.implements] = [ZoneSpecification]; | 4768 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
| 4769 let _rootMap = Symbol('_rootMap'); | 4769 let _rootMap = Symbol('_rootMap'); |
| 4770 let _rootDelegate = Symbol('_rootDelegate'); | 4770 let _rootDelegate = Symbol('_rootDelegate'); |
| 4771 class _RootZone extends _Zone { | 4771 class _RootZone extends _Zone { |
| 4772 _RootZone() { | 4772 _RootZone() { |
| 4773 super._Zone(); | 4773 super._Zone(); |
| 4774 } | 4774 } |
| 4775 get [_run]() { | 4775 get [_run]() { |
| 4776 return new _ZoneFunction(_ROOT_ZONE, _rootRun); | 4776 return new _ZoneFunction(_ROOT_ZONE, _rootRun); |
| 4777 } | 4777 } |
| 4778 get [_runUnary]() { | 4778 get [_runUnary]() { |
| (...skipping 233 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5012 exports.StreamIterator = StreamIterator; | 5012 exports.StreamIterator = StreamIterator; |
| 5013 exports.StreamIterator$ = StreamIterator$; | 5013 exports.StreamIterator$ = StreamIterator$; |
| 5014 exports.StreamController = StreamController; | 5014 exports.StreamController = StreamController; |
| 5015 exports.StreamController$ = StreamController$; | 5015 exports.StreamController$ = StreamController$; |
| 5016 exports.Timer = Timer; | 5016 exports.Timer = Timer; |
| 5017 exports.ZoneSpecification = ZoneSpecification; | 5017 exports.ZoneSpecification = ZoneSpecification; |
| 5018 exports.ZoneDelegate = ZoneDelegate; | 5018 exports.ZoneDelegate = ZoneDelegate; |
| 5019 exports.Zone = Zone; | 5019 exports.Zone = Zone; |
| 5020 exports.runZoned = runZoned; | 5020 exports.runZoned = runZoned; |
| 5021 })(async || (async = {})); | 5021 })(async || (async = {})); |
| OLD | NEW |