| 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 methods: () => ({toString: dart.functionType(core.String, [])}) | |
| 37 }); | |
| 38 class _UncaughtAsyncError extends AsyncError { | 35 class _UncaughtAsyncError extends AsyncError { |
| 39 _UncaughtAsyncError(error, stackTrace) { | 36 _UncaughtAsyncError(error, stackTrace) { |
| 40 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac
kTrace)); | 37 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac
kTrace)); |
| 41 } | 38 } |
| 42 static _getBestStackTrace(error, stackTrace) { | 39 static _getBestStackTrace(error, stackTrace) { |
| 43 if (stackTrace != null) | 40 if (stackTrace != null) |
| 44 return stackTrace; | 41 return stackTrace; |
| 45 if (dart.is(error, core.Error)) { | 42 if (dart.is(error, core.Error)) { |
| 46 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); | 43 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); |
| 47 } | 44 } |
| 48 return null; | 45 return null; |
| 49 } | 46 } |
| 50 toString() { | 47 toString() { |
| 51 let result = `Uncaught Error: ${this.error}`; | 48 let result = `Uncaught Error: ${this.error}`; |
| 52 if (this.stackTrace != null) { | 49 if (this.stackTrace != null) { |
| 53 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; | 50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; |
| 54 } | 51 } |
| 55 return result; | 52 return result; |
| 56 } | 53 } |
| 57 } | 54 } |
| 58 dart.setSignature(_UncaughtAsyncError, { | 55 dart.setSignature(_UncaughtAsyncError, { |
| 59 methods: () => ({toString: dart.functionType(core.String, [])}), | |
| 60 statics: () => ({_getBestStackTrace: dart.functionType(core.StackTrace, [dar
t.dynamic, core.StackTrace])}), | 56 statics: () => ({_getBestStackTrace: dart.functionType(core.StackTrace, [dar
t.dynamic, core.StackTrace])}), |
| 61 names: ['_getBestStackTrace'] | 57 names: ['_getBestStackTrace'] |
| 62 }); | 58 }); |
| 63 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); | 59 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); |
| 64 let _add = Symbol('_add'); | 60 let _add = Symbol('_add'); |
| 65 let _closeUnchecked = Symbol('_closeUnchecked'); | 61 let _closeUnchecked = Symbol('_closeUnchecked'); |
| 66 let _addError = Symbol('_addError'); | 62 let _addError = Symbol('_addError'); |
| 67 let _completeError = Symbol('_completeError'); | 63 let _completeError = Symbol('_completeError'); |
| 68 let _complete = Symbol('_complete'); | 64 let _complete = Symbol('_complete'); |
| 69 let _sink = Symbol('_sink'); | 65 let _sink = Symbol('_sink'); |
| (...skipping 758 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 828 let _ControllerStream = _ControllerStream$(); | 824 let _ControllerStream = _ControllerStream$(); |
| 829 let _BroadcastStream$ = dart.generic(function(T) { | 825 let _BroadcastStream$ = dart.generic(function(T) { |
| 830 class _BroadcastStream extends _ControllerStream$(T) { | 826 class _BroadcastStream extends _ControllerStream$(T) { |
| 831 _BroadcastStream(controller) { | 827 _BroadcastStream(controller) { |
| 832 super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$(
T))); | 828 super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$(
T))); |
| 833 } | 829 } |
| 834 get isBroadcast() { | 830 get isBroadcast() { |
| 835 return true; | 831 return true; |
| 836 } | 832 } |
| 837 } | 833 } |
| 838 dart.setSignature(_BroadcastStream, {}); | |
| 839 return _BroadcastStream; | 834 return _BroadcastStream; |
| 840 }); | 835 }); |
| 841 let _BroadcastStream = _BroadcastStream$(); | 836 let _BroadcastStream = _BroadcastStream$(); |
| 842 let _next = Symbol('_next'); | 837 let _next = Symbol('_next'); |
| 843 let _previous = Symbol('_previous'); | 838 let _previous = Symbol('_previous'); |
| 844 class _BroadcastSubscriptionLink extends core.Object { | 839 class _BroadcastSubscriptionLink extends core.Object { |
| 845 _BroadcastSubscriptionLink() { | 840 _BroadcastSubscriptionLink() { |
| 846 this[_next] = null; | 841 this[_next] = null; |
| 847 this[_previous] = null; | 842 this[_previous] = null; |
| 848 } | 843 } |
| 849 } | 844 } |
| 850 dart.setSignature(_BroadcastSubscriptionLink, {}); | |
| 851 let _zone = Symbol('_zone'); | 845 let _zone = Symbol('_zone'); |
| 852 let _state = Symbol('_state'); | 846 let _state = Symbol('_state'); |
| 853 let _onData = Symbol('_onData'); | 847 let _onData = Symbol('_onData'); |
| 854 let _onError = Symbol('_onError'); | 848 let _onError = Symbol('_onError'); |
| 855 let _onDone = Symbol('_onDone'); | 849 let _onDone = Symbol('_onDone'); |
| 856 let _cancelFuture = Symbol('_cancelFuture'); | 850 let _cancelFuture = Symbol('_cancelFuture'); |
| 857 let _pending = Symbol('_pending'); | 851 let _pending = Symbol('_pending'); |
| 858 let _setPendingEvents = Symbol('_setPendingEvents'); | 852 let _setPendingEvents = Symbol('_setPendingEvents'); |
| 859 let _extractPending = Symbol('_extractPending'); | 853 let _extractPending = Symbol('_extractPending'); |
| 860 let _isCanceled = Symbol('_isCanceled'); | 854 let _isCanceled = Symbol('_isCanceled'); |
| (...skipping 363 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1224 [_onCancel]() { | 1218 [_onCancel]() { |
| 1225 return this[_controller][_recordCancel](this); | 1219 return this[_controller][_recordCancel](this); |
| 1226 } | 1220 } |
| 1227 [_onPause]() { | 1221 [_onPause]() { |
| 1228 this[_controller][_recordPause](this); | 1222 this[_controller][_recordPause](this); |
| 1229 } | 1223 } |
| 1230 [_onResume]() { | 1224 [_onResume]() { |
| 1231 this[_controller][_recordResume](this); | 1225 this[_controller][_recordResume](this); |
| 1232 } | 1226 } |
| 1233 } | 1227 } |
| 1234 dart.setSignature(_ControllerSubscription, { | |
| 1235 methods: () => ({ | |
| 1236 [_onCancel]: dart.functionType(Future, []), | |
| 1237 [_onPause]: dart.functionType(dart.void, []), | |
| 1238 [_onResume]: dart.functionType(dart.void, []) | |
| 1239 }) | |
| 1240 }); | |
| 1241 return _ControllerSubscription; | 1228 return _ControllerSubscription; |
| 1242 }); | 1229 }); |
| 1243 let _ControllerSubscription = _ControllerSubscription$(); | 1230 let _ControllerSubscription = _ControllerSubscription$(); |
| 1244 let _eventState = Symbol('_eventState'); | 1231 let _eventState = Symbol('_eventState'); |
| 1245 let _expectsEvent = Symbol('_expectsEvent'); | 1232 let _expectsEvent = Symbol('_expectsEvent'); |
| 1246 let _toggleEventId = Symbol('_toggleEventId'); | 1233 let _toggleEventId = Symbol('_toggleEventId'); |
| 1247 let _isFiring = Symbol('_isFiring'); | 1234 let _isFiring = Symbol('_isFiring'); |
| 1248 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); | 1235 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); |
| 1249 let _removeAfterFiring = Symbol('_removeAfterFiring'); | 1236 let _removeAfterFiring = Symbol('_removeAfterFiring'); |
| 1250 let _BroadcastSubscription$ = dart.generic(function(T) { | 1237 let _BroadcastSubscription$ = dart.generic(function(T) { |
| (...skipping 25 matching lines...) Expand all Loading... |
| 1276 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption$()._STATE_REMOVE_AFTER_FIRING)) != 0; | 1263 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption$()._STATE_REMOVE_AFTER_FIRING)) != 0; |
| 1277 } | 1264 } |
| 1278 [_onPause]() {} | 1265 [_onPause]() {} |
| 1279 [_onResume]() {} | 1266 [_onResume]() {} |
| 1280 } | 1267 } |
| 1281 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink]
; | 1268 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink]
; |
| 1282 dart.setSignature(_BroadcastSubscription, { | 1269 dart.setSignature(_BroadcastSubscription, { |
| 1283 methods: () => ({ | 1270 methods: () => ({ |
| 1284 [_expectsEvent]: dart.functionType(core.bool, [core.int]), | 1271 [_expectsEvent]: dart.functionType(core.bool, [core.int]), |
| 1285 [_toggleEventId]: dart.functionType(dart.void, []), | 1272 [_toggleEventId]: dart.functionType(dart.void, []), |
| 1286 [_setRemoveAfterFiring]: dart.functionType(dart.void, []), | 1273 [_setRemoveAfterFiring]: dart.functionType(dart.void, []) |
| 1287 [_onPause]: dart.functionType(dart.void, []), | |
| 1288 [_onResume]: dart.functionType(dart.void, []) | |
| 1289 }) | 1274 }) |
| 1290 }); | 1275 }); |
| 1291 return _BroadcastSubscription; | 1276 return _BroadcastSubscription; |
| 1292 }); | 1277 }); |
| 1293 let _BroadcastSubscription = _BroadcastSubscription$(); | 1278 let _BroadcastSubscription = _BroadcastSubscription$(); |
| 1294 _BroadcastSubscription._STATE_EVENT_ID = 1; | 1279 _BroadcastSubscription._STATE_EVENT_ID = 1; |
| 1295 _BroadcastSubscription._STATE_FIRING = 2; | 1280 _BroadcastSubscription._STATE_FIRING = 2; |
| 1296 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; | 1281 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; |
| 1297 let _addStreamState = Symbol('_addStreamState'); | 1282 let _addStreamState = Symbol('_addStreamState'); |
| 1298 let _doneFuture = Symbol('_doneFuture'); | 1283 let _doneFuture = Symbol('_doneFuture'); |
| (...skipping 397 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1696 this[_pending].clear(); | 1681 this[_pending].clear(); |
| 1697 this[_pending] = null; | 1682 this[_pending] = null; |
| 1698 } | 1683 } |
| 1699 super[_callOnCancel](); | 1684 super[_callOnCancel](); |
| 1700 } | 1685 } |
| 1701 } | 1686 } |
| 1702 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)]; | 1687 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)]; |
| 1703 dart.setSignature(_AsBroadcastStreamController, { | 1688 dart.setSignature(_AsBroadcastStreamController, { |
| 1704 methods: () => ({ | 1689 methods: () => ({ |
| 1705 [_addPendingEvent]: dart.functionType(dart.void, [_DelayedEvent]), | 1690 [_addPendingEvent]: dart.functionType(dart.void, [_DelayedEvent]), |
| 1706 add: dart.functionType(dart.void, [T]), | 1691 add: dart.functionType(dart.void, [T]) |
| 1707 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace])
, | |
| 1708 close: dart.functionType(Future, []), | |
| 1709 [_callOnCancel]: dart.functionType(dart.void, []) | |
| 1710 }) | 1692 }) |
| 1711 }); | 1693 }); |
| 1712 return _AsBroadcastStreamController; | 1694 return _AsBroadcastStreamController; |
| 1713 }); | 1695 }); |
| 1714 let _AsBroadcastStreamController = _AsBroadcastStreamController$(); | 1696 let _AsBroadcastStreamController = _AsBroadcastStreamController$(); |
| 1715 let _pauseCount = Symbol('_pauseCount'); | 1697 let _pauseCount = Symbol('_pauseCount'); |
| 1716 let _resume = Symbol('_resume'); | 1698 let _resume = Symbol('_resume'); |
| 1717 let _DoneSubscription$ = dart.generic(function(T) { | 1699 let _DoneSubscription$ = dart.generic(function(T) { |
| 1718 class _DoneSubscription extends core.Object { | 1700 class _DoneSubscription extends core.Object { |
| 1719 _DoneSubscription() { | 1701 _DoneSubscription() { |
| (...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1790 let _s = Symbol('_s'); | 1772 let _s = Symbol('_s'); |
| 1791 class DeferredLoadException extends core.Object { | 1773 class DeferredLoadException extends core.Object { |
| 1792 DeferredLoadException(s) { | 1774 DeferredLoadException(s) { |
| 1793 this[_s] = s; | 1775 this[_s] = s; |
| 1794 } | 1776 } |
| 1795 toString() { | 1777 toString() { |
| 1796 return `DeferredLoadException: '${this[_s]}'`; | 1778 return `DeferredLoadException: '${this[_s]}'`; |
| 1797 } | 1779 } |
| 1798 } | 1780 } |
| 1799 DeferredLoadException[dart.implements] = () => [core.Exception]; | 1781 DeferredLoadException[dart.implements] = () => [core.Exception]; |
| 1800 dart.setSignature(DeferredLoadException, { | |
| 1801 methods: () => ({toString: dart.functionType(core.String, [])}) | |
| 1802 }); | |
| 1803 let _completeWithValue = Symbol('_completeWithValue'); | 1782 let _completeWithValue = Symbol('_completeWithValue'); |
| 1804 let Future$ = dart.generic(function(T) { | 1783 let Future$ = dart.generic(function(T) { |
| 1805 class Future extends core.Object { | 1784 class Future extends core.Object { |
| 1806 Future(computation) { | 1785 Future(computation) { |
| 1807 let result = new (_Future$(T))(); | 1786 let result = new (_Future$(T))(); |
| 1808 Timer.run(dart.fn(() => { | 1787 Timer.run(dart.fn(() => { |
| 1809 try { | 1788 try { |
| 1810 result[_complete](computation()); | 1789 result[_complete](computation()); |
| 1811 } catch (e) { | 1790 } catch (e) { |
| 1812 let s = dart.stackTrace(e); | 1791 let s = dart.stackTrace(e); |
| (...skipping 175 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1988 toString() { | 1967 toString() { |
| 1989 let result = "TimeoutException"; | 1968 let result = "TimeoutException"; |
| 1990 if (this.duration != null) | 1969 if (this.duration != null) |
| 1991 result = `TimeoutException after ${this.duration}`; | 1970 result = `TimeoutException after ${this.duration}`; |
| 1992 if (this.message != null) | 1971 if (this.message != null) |
| 1993 result = `${result}: ${this.message}`; | 1972 result = `${result}: ${this.message}`; |
| 1994 return result; | 1973 return result; |
| 1995 } | 1974 } |
| 1996 } | 1975 } |
| 1997 TimeoutException[dart.implements] = () => [core.Exception]; | 1976 TimeoutException[dart.implements] = () => [core.Exception]; |
| 1998 dart.setSignature(TimeoutException, { | |
| 1999 methods: () => ({toString: dart.functionType(core.String, [])}) | |
| 2000 }); | |
| 2001 let Completer$ = dart.generic(function(T) { | 1977 let Completer$ = dart.generic(function(T) { |
| 2002 class Completer extends core.Object { | 1978 class Completer extends core.Object { |
| 2003 Completer() { | 1979 Completer() { |
| 2004 return new (_AsyncCompleter$(T))(); | 1980 return new (_AsyncCompleter$(T))(); |
| 2005 } | 1981 } |
| 2006 sync() { | 1982 sync() { |
| 2007 return new (_SyncCompleter$(T))(); | 1983 return new (_SyncCompleter$(T))(); |
| 2008 } | 1984 } |
| 2009 } | 1985 } |
| 2010 dart.defineNamedConstructor(Completer, 'sync'); | 1986 dart.defineNamedConstructor(Completer, 'sync'); |
| 2011 dart.setSignature(Completer, {}); | |
| 2012 return Completer; | 1987 return Completer; |
| 2013 }); | 1988 }); |
| 2014 let Completer = Completer$(); | 1989 let Completer = Completer$(); |
| 2015 function _completeWithErrorCallback(result, error, stackTrace) { | 1990 function _completeWithErrorCallback(result, error, stackTrace) { |
| 2016 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); | 1991 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); |
| 2017 if (replacement != null) { | 1992 if (replacement != null) { |
| 2018 error = _nonNullError(replacement.error); | 1993 error = _nonNullError(replacement.error); |
| 2019 stackTrace = replacement.stackTrace; | 1994 stackTrace = replacement.stackTrace; |
| 2020 } | 1995 } |
| 2021 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 1996 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
| (...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2174 } | 2149 } |
| 2175 get [_whenCompleteAction]() { | 2150 get [_whenCompleteAction]() { |
| 2176 dart.assert(this.handlesComplete); | 2151 dart.assert(this.handlesComplete); |
| 2177 return dart.as(this.callback, _FutureAction); | 2152 return dart.as(this.callback, _FutureAction); |
| 2178 } | 2153 } |
| 2179 } | 2154 } |
| 2180 dart.defineNamedConstructor(_FutureListener, 'then'); | 2155 dart.defineNamedConstructor(_FutureListener, 'then'); |
| 2181 dart.defineNamedConstructor(_FutureListener, 'catchError'); | 2156 dart.defineNamedConstructor(_FutureListener, 'catchError'); |
| 2182 dart.defineNamedConstructor(_FutureListener, 'whenComplete'); | 2157 dart.defineNamedConstructor(_FutureListener, 'whenComplete'); |
| 2183 dart.defineNamedConstructor(_FutureListener, 'chain'); | 2158 dart.defineNamedConstructor(_FutureListener, 'chain'); |
| 2184 dart.setSignature(_FutureListener, {}); | |
| 2185 _FutureListener.MASK_VALUE = 1; | 2159 _FutureListener.MASK_VALUE = 1; |
| 2186 _FutureListener.MASK_ERROR = 2; | 2160 _FutureListener.MASK_ERROR = 2; |
| 2187 _FutureListener.MASK_TEST_ERROR = 4; | 2161 _FutureListener.MASK_TEST_ERROR = 4; |
| 2188 _FutureListener.MASK_WHENCOMPLETE = 8; | 2162 _FutureListener.MASK_WHENCOMPLETE = 8; |
| 2189 _FutureListener.STATE_CHAIN = 0; | 2163 _FutureListener.STATE_CHAIN = 0; |
| 2190 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE; | 2164 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE; |
| 2191 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE)
| dart.notNull(_FutureListener.MASK_ERROR); | 2165 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE)
| dart.notNull(_FutureListener.MASK_ERROR); |
| 2192 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR; | 2166 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR; |
| 2193 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO
R) | dart.notNull(_FutureListener.MASK_TEST_ERROR); | 2167 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO
R) | dart.notNull(_FutureListener.MASK_TEST_ERROR); |
| 2194 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE; | 2168 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE; |
| (...skipping 471 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2666 let __CastType6 = __CastType6$(); | 2640 let __CastType6 = __CastType6$(); |
| 2667 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.dynamic])); | 2641 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.dynamic])); |
| 2668 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | 2642 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
| 2669 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); | 2643 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); |
| 2670 class _AsyncCallbackEntry extends core.Object { | 2644 class _AsyncCallbackEntry extends core.Object { |
| 2671 _AsyncCallbackEntry(callback) { | 2645 _AsyncCallbackEntry(callback) { |
| 2672 this.callback = callback; | 2646 this.callback = callback; |
| 2673 this.next = null; | 2647 this.next = null; |
| 2674 } | 2648 } |
| 2675 } | 2649 } |
| 2676 dart.setSignature(_AsyncCallbackEntry, {}); | |
| 2677 exports._nextCallback = null; | 2650 exports._nextCallback = null; |
| 2678 exports._lastCallback = null; | 2651 exports._lastCallback = null; |
| 2679 exports._lastPriorityCallback = null; | 2652 exports._lastPriorityCallback = null; |
| 2680 exports._isInCallbackLoop = false; | 2653 exports._isInCallbackLoop = false; |
| 2681 function _asyncRunCallbackLoop() { | 2654 function _asyncRunCallbackLoop() { |
| 2682 while (exports._nextCallback != null) { | 2655 while (exports._nextCallback != null) { |
| 2683 exports._lastPriorityCallback = null; | 2656 exports._lastPriorityCallback = null; |
| 2684 let entry = exports._nextCallback; | 2657 let entry = exports._nextCallback; |
| 2685 exports._nextCallback = entry.next; | 2658 exports._nextCallback = entry.next; |
| 2686 if (exports._nextCallback == null) | 2659 if (exports._nextCallback == null) |
| (...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2808 }), | 2781 }), |
| 2809 names: ['_scheduleImmediate', '_initializeScheduleImmediate', '_scheduleImme
diateJsOverride', '_scheduleImmediateWithSetImmediate', '_scheduleImmediateWithT
imer'] | 2782 names: ['_scheduleImmediate', '_initializeScheduleImmediate', '_scheduleImme
diateJsOverride', '_scheduleImmediateWithSetImmediate', '_scheduleImmediateWithT
imer'] |
| 2810 }); | 2783 }); |
| 2811 dart.defineLazyProperties(_AsyncRun, { | 2784 dart.defineLazyProperties(_AsyncRun, { |
| 2812 get scheduleImmediateClosure() { | 2785 get scheduleImmediateClosure() { |
| 2813 return _AsyncRun._initializeScheduleImmediate(); | 2786 return _AsyncRun._initializeScheduleImmediate(); |
| 2814 } | 2787 } |
| 2815 }); | 2788 }); |
| 2816 let StreamSubscription$ = dart.generic(function(T) { | 2789 let StreamSubscription$ = dart.generic(function(T) { |
| 2817 class StreamSubscription extends core.Object {} | 2790 class StreamSubscription extends core.Object {} |
| 2818 dart.setSignature(StreamSubscription, {}); | |
| 2819 return StreamSubscription; | 2791 return StreamSubscription; |
| 2820 }); | 2792 }); |
| 2821 let StreamSubscription = StreamSubscription$(); | 2793 let StreamSubscription = StreamSubscription$(); |
| 2822 let EventSink$ = dart.generic(function(T) { | 2794 let EventSink$ = dart.generic(function(T) { |
| 2823 class EventSink extends core.Object {} | 2795 class EventSink extends core.Object {} |
| 2824 EventSink[dart.implements] = () => [core.Sink$(T)]; | 2796 EventSink[dart.implements] = () => [core.Sink$(T)]; |
| 2825 dart.setSignature(EventSink, {}); | |
| 2826 return EventSink; | 2797 return EventSink; |
| 2827 }); | 2798 }); |
| 2828 let EventSink = EventSink$(); | 2799 let EventSink = EventSink$(); |
| 2829 let _stream = Symbol('_stream'); | 2800 let _stream = Symbol('_stream'); |
| 2830 let StreamView$ = dart.generic(function(T) { | 2801 let StreamView$ = dart.generic(function(T) { |
| 2831 class StreamView extends Stream$(T) { | 2802 class StreamView extends Stream$(T) { |
| 2832 StreamView(stream) { | 2803 StreamView(stream) { |
| 2833 this[_stream] = stream; | 2804 this[_stream] = stream; |
| 2834 super.Stream(); | 2805 super.Stream(); |
| 2835 } | 2806 } |
| (...skipping 20 matching lines...) Expand all Loading... |
| 2856 methods: () => ({ | 2827 methods: () => ({ |
| 2857 asBroadcastStream: dart.functionType(Stream$(T), [], {nListe: dart.funct
ionType(dart.void, [StreamSubscription$(T)]), nCance: dart.functionType(dart.voi
d, [StreamSubscription$(T)])}), | 2828 asBroadcastStream: dart.functionType(Stream$(T), [], {nListe: dart.funct
ionType(dart.void, [StreamSubscription$(T)]), nCance: dart.functionType(dart.voi
d, [StreamSubscription$(T)])}), |
| 2858 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar
t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an
celOnErro: core.bool}) | 2829 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar
t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an
celOnErro: core.bool}) |
| 2859 }) | 2830 }) |
| 2860 }); | 2831 }); |
| 2861 return StreamView; | 2832 return StreamView; |
| 2862 }); | 2833 }); |
| 2863 let StreamView = StreamView$(); | 2834 let StreamView = StreamView$(); |
| 2864 let StreamConsumer$ = dart.generic(function(S) { | 2835 let StreamConsumer$ = dart.generic(function(S) { |
| 2865 class StreamConsumer extends core.Object {} | 2836 class StreamConsumer extends core.Object {} |
| 2866 dart.setSignature(StreamConsumer, {}); | |
| 2867 return StreamConsumer; | 2837 return StreamConsumer; |
| 2868 }); | 2838 }); |
| 2869 let StreamConsumer = StreamConsumer$(); | 2839 let StreamConsumer = StreamConsumer$(); |
| 2870 let StreamSink$ = dart.generic(function(S) { | 2840 let StreamSink$ = dart.generic(function(S) { |
| 2871 class StreamSink extends core.Object {} | 2841 class StreamSink extends core.Object {} |
| 2872 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)]; | 2842 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)]; |
| 2873 dart.setSignature(StreamSink, {}); | |
| 2874 return StreamSink; | 2843 return StreamSink; |
| 2875 }); | 2844 }); |
| 2876 let StreamSink = StreamSink$(); | 2845 let StreamSink = StreamSink$(); |
| 2877 let StreamTransformer$ = dart.generic(function(S, T) { | 2846 let StreamTransformer$ = dart.generic(function(S, T) { |
| 2878 class StreamTransformer extends core.Object { | 2847 class StreamTransformer extends core.Object { |
| 2879 StreamTransformer(transformer) { | 2848 StreamTransformer(transformer) { |
| 2880 return new _StreamSubscriptionTransformer(transformer); | 2849 return new _StreamSubscriptionTransformer(transformer); |
| 2881 } | 2850 } |
| 2882 fromHandlers(opts) { | 2851 fromHandlers(opts) { |
| 2883 return new _StreamHandlerTransformer(opts); | 2852 return new _StreamHandlerTransformer(opts); |
| 2884 } | 2853 } |
| 2885 } | 2854 } |
| 2886 dart.defineNamedConstructor(StreamTransformer, 'fromHandlers'); | 2855 dart.defineNamedConstructor(StreamTransformer, 'fromHandlers'); |
| 2887 dart.setSignature(StreamTransformer, {}); | |
| 2888 return StreamTransformer; | 2856 return StreamTransformer; |
| 2889 }); | 2857 }); |
| 2890 let StreamTransformer = StreamTransformer$(); | 2858 let StreamTransformer = StreamTransformer$(); |
| 2891 let StreamIterator$ = dart.generic(function(T) { | 2859 let StreamIterator$ = dart.generic(function(T) { |
| 2892 class StreamIterator extends core.Object { | 2860 class StreamIterator extends core.Object { |
| 2893 StreamIterator(stream) { | 2861 StreamIterator(stream) { |
| 2894 return new (_StreamIteratorImpl$(T))(stream); | 2862 return new (_StreamIteratorImpl$(T))(stream); |
| 2895 } | 2863 } |
| 2896 } | 2864 } |
| 2897 dart.setSignature(StreamIterator, {}); | |
| 2898 return StreamIterator; | 2865 return StreamIterator; |
| 2899 }); | 2866 }); |
| 2900 let StreamIterator = StreamIterator$(); | 2867 let StreamIterator = StreamIterator$(); |
| 2901 let _ControllerEventSinkWrapper$ = dart.generic(function(T) { | 2868 let _ControllerEventSinkWrapper$ = dart.generic(function(T) { |
| 2902 class _ControllerEventSinkWrapper extends core.Object { | 2869 class _ControllerEventSinkWrapper extends core.Object { |
| 2903 _ControllerEventSinkWrapper(sink) { | 2870 _ControllerEventSinkWrapper(sink) { |
| 2904 this[_sink] = sink; | 2871 this[_sink] = sink; |
| 2905 } | 2872 } |
| 2906 add(data) { | 2873 add(data) { |
| 2907 dart.as(data, T); | 2874 dart.as(data, T); |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2946 } | 2913 } |
| 2947 broadcast(opts) { | 2914 broadcast(opts) { |
| 2948 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2915 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 2949 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2916 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 2950 let sync = opts && 'sync' in opts ? opts.sync : false; | 2917 let sync = opts && 'sync' in opts ? opts.sync : false; |
| 2951 return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCance
l) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel); | 2918 return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCance
l) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel); |
| 2952 } | 2919 } |
| 2953 } | 2920 } |
| 2954 StreamController[dart.implements] = () => [StreamSink$(T)]; | 2921 StreamController[dart.implements] = () => [StreamSink$(T)]; |
| 2955 dart.defineNamedConstructor(StreamController, 'broadcast'); | 2922 dart.defineNamedConstructor(StreamController, 'broadcast'); |
| 2956 dart.setSignature(StreamController, {}); | |
| 2957 return StreamController; | 2923 return StreamController; |
| 2958 }); | 2924 }); |
| 2959 let StreamController = StreamController$(); | 2925 let StreamController = StreamController$(); |
| 2960 let _StreamControllerLifecycle$ = dart.generic(function(T) { | 2926 let _StreamControllerLifecycle$ = dart.generic(function(T) { |
| 2961 class _StreamControllerLifecycle extends core.Object { | 2927 class _StreamControllerLifecycle extends core.Object { |
| 2962 [_recordPause](subscription) { | 2928 [_recordPause](subscription) { |
| 2963 dart.as(subscription, StreamSubscription$(T)); | 2929 dart.as(subscription, StreamSubscription$(T)); |
| 2964 } | 2930 } |
| 2965 [_recordResume](subscription) { | 2931 [_recordResume](subscription) { |
| 2966 dart.as(subscription, StreamSubscription$(T)); | 2932 dart.as(subscription, StreamSubscription$(T)); |
| (...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3289 let _AsyncStreamController$ = dart.generic(function(T) { | 3255 let _AsyncStreamController$ = dart.generic(function(T) { |
| 3290 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { | 3256 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { |
| 3291 _AsyncStreamController(onListen, onPause, onResume, onCancel) { | 3257 _AsyncStreamController(onListen, onPause, onResume, onCancel) { |
| 3292 this[_onListen] = onListen; | 3258 this[_onListen] = onListen; |
| 3293 this[_onPause] = onPause; | 3259 this[_onPause] = onPause; |
| 3294 this[_onResume] = onResume; | 3260 this[_onResume] = onResume; |
| 3295 this[_onCancel] = onCancel; | 3261 this[_onCancel] = onCancel; |
| 3296 super._StreamController(); | 3262 super._StreamController(); |
| 3297 } | 3263 } |
| 3298 } | 3264 } |
| 3299 dart.setSignature(_AsyncStreamController, {}); | |
| 3300 return _AsyncStreamController; | 3265 return _AsyncStreamController; |
| 3301 }); | 3266 }); |
| 3302 let _AsyncStreamController = _AsyncStreamController$(); | 3267 let _AsyncStreamController = _AsyncStreamController$(); |
| 3303 let _SyncStreamController$ = dart.generic(function(T) { | 3268 let _SyncStreamController$ = dart.generic(function(T) { |
| 3304 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS
treamControllerDispatch$(T)) { | 3269 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS
treamControllerDispatch$(T)) { |
| 3305 _SyncStreamController(onListen, onPause, onResume, onCancel) { | 3270 _SyncStreamController(onListen, onPause, onResume, onCancel) { |
| 3306 this[_onListen] = onListen; | 3271 this[_onListen] = onListen; |
| 3307 this[_onPause] = onPause; | 3272 this[_onPause] = onPause; |
| 3308 this[_onResume] = onResume; | 3273 this[_onResume] = onResume; |
| 3309 this[_onCancel] = onCancel; | 3274 this[_onCancel] = onCancel; |
| 3310 super._StreamController(); | 3275 super._StreamController(); |
| 3311 } | 3276 } |
| 3312 } | 3277 } |
| 3313 dart.setSignature(_SyncStreamController, {}); | |
| 3314 return _SyncStreamController; | 3278 return _SyncStreamController; |
| 3315 }); | 3279 }); |
| 3316 let _SyncStreamController = _SyncStreamController$(); | 3280 let _SyncStreamController = _SyncStreamController$(); |
| 3317 class _NoCallbacks extends core.Object { | 3281 class _NoCallbacks extends core.Object { |
| 3318 get [_onListen]() { | 3282 get [_onListen]() { |
| 3319 return null; | 3283 return null; |
| 3320 } | 3284 } |
| 3321 get [_onPause]() { | 3285 get [_onPause]() { |
| 3322 return null; | 3286 return null; |
| 3323 } | 3287 } |
| 3324 get [_onResume]() { | 3288 get [_onResume]() { |
| 3325 return null; | 3289 return null; |
| 3326 } | 3290 } |
| 3327 get [_onCancel]() { | 3291 get [_onCancel]() { |
| 3328 return null; | 3292 return null; |
| 3329 } | 3293 } |
| 3330 } | 3294 } |
| 3331 dart.setSignature(_NoCallbacks, {}); | |
| 3332 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} | 3295 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} |
| 3333 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} | 3296 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} |
| 3334 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(dart.dynamic, [])); | 3297 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(dart.dynamic, [])); |
| 3335 function _runGuarded(notificationHandler) { | 3298 function _runGuarded(notificationHandler) { |
| 3336 if (notificationHandler == null) | 3299 if (notificationHandler == null) |
| 3337 return null; | 3300 return null; |
| 3338 try { | 3301 try { |
| 3339 let result = notificationHandler(); | 3302 let result = notificationHandler(); |
| 3340 if (dart.is(result, Future)) | 3303 if (dart.is(result, Future)) |
| 3341 return dart.as(result, Future); | 3304 return dart.as(result, Future); |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3434 let _StreamControllerAddStreamState$ = dart.generic(function(T) { | 3397 let _StreamControllerAddStreamState$ = dart.generic(function(T) { |
| 3435 class _StreamControllerAddStreamState extends _AddStreamState$(T) { | 3398 class _StreamControllerAddStreamState extends _AddStreamState$(T) { |
| 3436 _StreamControllerAddStreamState(controller, varData, source, cancelOnError
) { | 3399 _StreamControllerAddStreamState(controller, varData, source, cancelOnError
) { |
| 3437 this.varData = varData; | 3400 this.varData = varData; |
| 3438 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance
lOnError); | 3401 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance
lOnError); |
| 3439 if (controller.isPaused) { | 3402 if (controller.isPaused) { |
| 3440 this.addSubscription.pause(); | 3403 this.addSubscription.pause(); |
| 3441 } | 3404 } |
| 3442 } | 3405 } |
| 3443 } | 3406 } |
| 3444 dart.setSignature(_StreamControllerAddStreamState, {}); | |
| 3445 return _StreamControllerAddStreamState; | 3407 return _StreamControllerAddStreamState; |
| 3446 }); | 3408 }); |
| 3447 let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(); | 3409 let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(); |
| 3448 let _EventSink$ = dart.generic(function(T) { | 3410 let _EventSink$ = dart.generic(function(T) { |
| 3449 class _EventSink extends core.Object {} | 3411 class _EventSink extends core.Object {} |
| 3450 dart.setSignature(_EventSink, {}); | |
| 3451 return _EventSink; | 3412 return _EventSink; |
| 3452 }); | 3413 }); |
| 3453 let _EventSink = _EventSink$(); | 3414 let _EventSink = _EventSink$(); |
| 3454 let _EventDispatch$ = dart.generic(function(T) { | 3415 let _EventDispatch$ = dart.generic(function(T) { |
| 3455 class _EventDispatch extends core.Object {} | 3416 class _EventDispatch extends core.Object {} |
| 3456 dart.setSignature(_EventDispatch, {}); | |
| 3457 return _EventDispatch; | 3417 return _EventDispatch; |
| 3458 }); | 3418 }); |
| 3459 let _EventDispatch = _EventDispatch$(); | 3419 let _EventDispatch = _EventDispatch$(); |
| 3460 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; | 3420 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; |
| 3461 _BufferingStreamSubscription._STATE_CLOSED = 2; | 3421 _BufferingStreamSubscription._STATE_CLOSED = 2; |
| 3462 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; | 3422 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; |
| 3463 _BufferingStreamSubscription._STATE_CANCELED = 8; | 3423 _BufferingStreamSubscription._STATE_CANCELED = 8; |
| 3464 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; | 3424 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; |
| 3465 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; | 3425 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; |
| 3466 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; | 3426 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3596 dart.fn(_nullErrorHandler, dart.void, [dart.dynamic], [core.StackTrace]); | 3556 dart.fn(_nullErrorHandler, dart.void, [dart.dynamic], [core.StackTrace]); |
| 3597 function _nullDoneHandler() { | 3557 function _nullDoneHandler() { |
| 3598 } | 3558 } |
| 3599 dart.fn(_nullDoneHandler, dart.void, []); | 3559 dart.fn(_nullDoneHandler, dart.void, []); |
| 3600 let _DelayedEvent$ = dart.generic(function(T) { | 3560 let _DelayedEvent$ = dart.generic(function(T) { |
| 3601 class _DelayedEvent extends core.Object { | 3561 class _DelayedEvent extends core.Object { |
| 3602 _DelayedEvent() { | 3562 _DelayedEvent() { |
| 3603 this.next = null; | 3563 this.next = null; |
| 3604 } | 3564 } |
| 3605 } | 3565 } |
| 3606 dart.setSignature(_DelayedEvent, {}); | |
| 3607 return _DelayedEvent; | 3566 return _DelayedEvent; |
| 3608 }); | 3567 }); |
| 3609 let _DelayedEvent = _DelayedEvent$(); | 3568 let _DelayedEvent = _DelayedEvent$(); |
| 3610 let _DelayedData$ = dart.generic(function(T) { | 3569 let _DelayedData$ = dart.generic(function(T) { |
| 3611 class _DelayedData extends _DelayedEvent$(T) { | 3570 class _DelayedData extends _DelayedEvent$(T) { |
| 3612 _DelayedData(value) { | 3571 _DelayedData(value) { |
| 3613 this.value = value; | 3572 this.value = value; |
| 3614 super._DelayedEvent(); | 3573 super._DelayedEvent(); |
| 3615 } | 3574 } |
| 3616 perform(dispatch) { | 3575 perform(dispatch) { |
| (...skipping 620 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4237 [_handleError](error, stackTrace) { | 4196 [_handleError](error, stackTrace) { |
| 4238 this[_stream][_handleError](error, stackTrace, this); | 4197 this[_stream][_handleError](error, stackTrace, this); |
| 4239 } | 4198 } |
| 4240 [_handleDone]() { | 4199 [_handleDone]() { |
| 4241 this[_stream][_handleDone](this); | 4200 this[_stream][_handleDone](this); |
| 4242 } | 4201 } |
| 4243 } | 4202 } |
| 4244 dart.setSignature(_ForwardingStreamSubscription, { | 4203 dart.setSignature(_ForwardingStreamSubscription, { |
| 4245 methods: () => ({ | 4204 methods: () => ({ |
| 4246 [_add]: dart.functionType(dart.void, [T]), | 4205 [_add]: dart.functionType(dart.void, [T]), |
| 4247 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace]
), | |
| 4248 [_onPause]: dart.functionType(dart.void, []), | |
| 4249 [_onResume]: dart.functionType(dart.void, []), | |
| 4250 [_onCancel]: dart.functionType(Future, []), | |
| 4251 [_handleData]: dart.functionType(dart.void, [S]), | 4206 [_handleData]: dart.functionType(dart.void, [S]), |
| 4252 [_handleError]: dart.functionType(dart.void, [dart.dynamic, core.StackTr
ace]), | 4207 [_handleError]: dart.functionType(dart.void, [dart.dynamic, core.StackTr
ace]), |
| 4253 [_handleDone]: dart.functionType(dart.void, []) | 4208 [_handleDone]: dart.functionType(dart.void, []) |
| 4254 }) | 4209 }) |
| 4255 }); | 4210 }); |
| 4256 return _ForwardingStreamSubscription; | 4211 return _ForwardingStreamSubscription; |
| 4257 }); | 4212 }); |
| 4258 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); | 4213 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); |
| 4259 let _Predicate$ = dart.generic(function(T) { | 4214 let _Predicate$ = dart.generic(function(T) { |
| 4260 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); | 4215 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); |
| (...skipping 427 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4688 } catch (e) { | 4643 } catch (e) { |
| 4689 let s = dart.stackTrace(e); | 4644 let s = dart.stackTrace(e); |
| 4690 this[_addError](e, s); | 4645 this[_addError](e, s); |
| 4691 } | 4646 } |
| 4692 | 4647 |
| 4693 } | 4648 } |
| 4694 } | 4649 } |
| 4695 dart.setSignature(_SinkTransformerStreamSubscription, { | 4650 dart.setSignature(_SinkTransformerStreamSubscription, { |
| 4696 methods: () => ({ | 4651 methods: () => ({ |
| 4697 [_add]: dart.functionType(dart.void, [T]), | 4652 [_add]: dart.functionType(dart.void, [T]), |
| 4698 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace]
), | |
| 4699 [_close]: dart.functionType(dart.void, []), | |
| 4700 [_onPause]: dart.functionType(dart.void, []), | |
| 4701 [_onResume]: dart.functionType(dart.void, []), | |
| 4702 [_onCancel]: dart.functionType(Future, []), | |
| 4703 [_handleData]: dart.functionType(dart.void, [S]), | 4653 [_handleData]: dart.functionType(dart.void, [S]), |
| 4704 [_handleError]: dart.functionType(dart.void, [dart.dynamic], [dart.dynam
ic]), | 4654 [_handleError]: dart.functionType(dart.void, [dart.dynamic], [dart.dynam
ic]), |
| 4705 [_handleDone]: dart.functionType(dart.void, []) | 4655 [_handleDone]: dart.functionType(dart.void, []) |
| 4706 }) | 4656 }) |
| 4707 }); | 4657 }); |
| 4708 return _SinkTransformerStreamSubscription; | 4658 return _SinkTransformerStreamSubscription; |
| 4709 }); | 4659 }); |
| 4710 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; | 4660 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; |
| 4711 let _SinkMapper$ = dart.generic(function(S, T) { | 4661 let _SinkMapper$ = dart.generic(function(S, T) { |
| 4712 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); | 4662 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); |
| (...skipping 249 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4962 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); | 4912 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); |
| 4963 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); | 4913 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); |
| 4964 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); | 4914 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); |
| 4965 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); | 4915 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); |
| 4966 class _ZoneFunction extends core.Object { | 4916 class _ZoneFunction extends core.Object { |
| 4967 _ZoneFunction(zone, func) { | 4917 _ZoneFunction(zone, func) { |
| 4968 this.zone = zone; | 4918 this.zone = zone; |
| 4969 this.function = func; | 4919 this.function = func; |
| 4970 } | 4920 } |
| 4971 } | 4921 } |
| 4972 dart.setSignature(_ZoneFunction, {}); | |
| 4973 class ZoneSpecification extends core.Object { | 4922 class ZoneSpecification extends core.Object { |
| 4974 ZoneSpecification(opts) { | 4923 ZoneSpecification(opts) { |
| 4975 return new _ZoneSpecification(opts); | 4924 return new _ZoneSpecification(opts); |
| 4976 } | 4925 } |
| 4977 from(other, opts) { | 4926 from(other, opts) { |
| 4978 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; | 4927 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; |
| 4979 let run = opts && 'run' in opts ? opts.run : null; | 4928 let run = opts && 'run' in opts ? opts.run : null; |
| 4980 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; | 4929 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; |
| 4981 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 4930 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
| 4982 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 4931 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
| 4983 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 4932 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
| 4984 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; | 4933 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; |
| 4985 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; | 4934 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; |
| 4986 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; | 4935 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; |
| 4987 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; | 4936 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; |
| 4988 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; | 4937 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; |
| 4989 let print = opts && 'print' in opts ? opts.print : null; | 4938 let print = opts && 'print' in opts ? opts.print : null; |
| 4990 let fork = opts && 'fork' in opts ? opts.fork : null; | 4939 let fork = opts && 'fork' in opts ? opts.fork : null; |
| 4991 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}); | 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}); |
| 4992 } | 4941 } |
| 4993 } | 4942 } |
| 4994 dart.defineNamedConstructor(ZoneSpecification, 'from'); | 4943 dart.defineNamedConstructor(ZoneSpecification, 'from'); |
| 4995 dart.setSignature(ZoneSpecification, {}); | |
| 4996 class _ZoneSpecification extends core.Object { | 4944 class _ZoneSpecification extends core.Object { |
| 4997 _ZoneSpecification(opts) { | 4945 _ZoneSpecification(opts) { |
| 4998 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; | 4946 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; |
| 4999 let run = opts && 'run' in opts ? opts.run : null; | 4947 let run = opts && 'run' in opts ? opts.run : null; |
| 5000 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; | 4948 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; |
| 5001 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 4949 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
| 5002 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 4950 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
| 5003 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 4951 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
| 5004 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; | 4952 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op
ts.registerBinaryCallback : null; |
| 5005 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; | 4953 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback :
null; |
| (...skipping 11 matching lines...) Expand all Loading... |
| 5017 this.registerBinaryCallback = registerBinaryCallback; | 4965 this.registerBinaryCallback = registerBinaryCallback; |
| 5018 this.errorCallback = errorCallback; | 4966 this.errorCallback = errorCallback; |
| 5019 this.scheduleMicrotask = scheduleMicrotask; | 4967 this.scheduleMicrotask = scheduleMicrotask; |
| 5020 this.createTimer = createTimer; | 4968 this.createTimer = createTimer; |
| 5021 this.createPeriodicTimer = createPeriodicTimer; | 4969 this.createPeriodicTimer = createPeriodicTimer; |
| 5022 this.print = print; | 4970 this.print = print; |
| 5023 this.fork = fork; | 4971 this.fork = fork; |
| 5024 } | 4972 } |
| 5025 } | 4973 } |
| 5026 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; | 4974 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
| 5027 dart.setSignature(_ZoneSpecification, {}); | |
| 5028 class ZoneDelegate extends core.Object {} | 4975 class ZoneDelegate extends core.Object {} |
| 5029 dart.setSignature(ZoneDelegate, {}); | |
| 5030 class Zone extends core.Object { | 4976 class Zone extends core.Object { |
| 5031 _() { | 4977 _() { |
| 5032 } | 4978 } |
| 5033 static get current() { | 4979 static get current() { |
| 5034 return Zone._current; | 4980 return Zone._current; |
| 5035 } | 4981 } |
| 5036 static _enter(zone) { | 4982 static _enter(zone) { |
| 5037 dart.assert(zone != null); | 4983 dart.assert(zone != null); |
| 5038 dart.assert(!dart.notNull(core.identical(zone, Zone._current))); | 4984 dart.assert(!dart.notNull(core.identical(zone, Zone._current))); |
| 5039 let previous = Zone._current; | 4985 let previous = Zone._current; |
| (...skipping 690 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5730 return _rootCreatePeriodicTimer; | 5676 return _rootCreatePeriodicTimer; |
| 5731 } | 5677 } |
| 5732 get print() { | 5678 get print() { |
| 5733 return _rootPrint; | 5679 return _rootPrint; |
| 5734 } | 5680 } |
| 5735 get fork() { | 5681 get fork() { |
| 5736 return _rootFork; | 5682 return _rootFork; |
| 5737 } | 5683 } |
| 5738 } | 5684 } |
| 5739 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; | 5685 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
| 5740 dart.setSignature(_RootZoneSpecification, {}); | |
| 5741 _RootZone._rootDelegate = null; | 5686 _RootZone._rootDelegate = null; |
| 5742 dart.defineLazyProperties(_RootZone, { | 5687 dart.defineLazyProperties(_RootZone, { |
| 5743 get _rootMap() { | 5688 get _rootMap() { |
| 5744 return new collection.HashMap(); | 5689 return new collection.HashMap(); |
| 5745 }, | 5690 }, |
| 5746 set _rootMap(_) {} | 5691 set _rootMap(_) {} |
| 5747 }); | 5692 }); |
| 5748 function runZoned(body, opts) { | 5693 function runZoned(body, opts) { |
| 5749 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 5694 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
| 5750 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; | 5695 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5831 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5776 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5832 exports.CreateTimerHandler = CreateTimerHandler; | 5777 exports.CreateTimerHandler = CreateTimerHandler; |
| 5833 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5778 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5834 exports.PrintHandler = PrintHandler; | 5779 exports.PrintHandler = PrintHandler; |
| 5835 exports.ForkHandler = ForkHandler; | 5780 exports.ForkHandler = ForkHandler; |
| 5836 exports.ZoneSpecification = ZoneSpecification; | 5781 exports.ZoneSpecification = ZoneSpecification; |
| 5837 exports.ZoneDelegate = ZoneDelegate; | 5782 exports.ZoneDelegate = ZoneDelegate; |
| 5838 exports.Zone = Zone; | 5783 exports.Zone = Zone; |
| 5839 exports.runZoned = runZoned; | 5784 exports.runZoned = runZoned; |
| 5840 })(async, core, _internal, _js_helper, _isolate_helper, collection); | 5785 })(async, core, _internal, _js_helper, _isolate_helper, collection); |
| OLD | NEW |