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.dcall(errorHandler, error, stackTrace); | 7 return dart.dcall(errorHandler, error, stackTrace); |
8 } else { | 8 } else { |
9 return dart.dcall(errorHandler, error); | 9 return dart.dcall(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.functionType(
dart.dynamic, [dart.dynamic]))); | 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.functionType(
dart.dynamic, [dart.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 dart.initField(AsyncError, this, 'error', error); |
24 this.stackTrace = stackTrace; | 24 dart.initField(AsyncError, this, 'stackTrace', stackTrace); |
25 } | 25 } |
26 toString() { | 26 toString() { |
27 return this.error.toString(); | 27 return this.error.toString(); |
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 } |
(...skipping 808 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
843 let _STATE_FIRING = Symbol('_STATE_FIRING'); | 843 let _STATE_FIRING = Symbol('_STATE_FIRING'); |
844 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); | 844 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); |
845 let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING'); | 845 let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING'); |
846 let _removeAfterFiring = Symbol('_removeAfterFiring'); | 846 let _removeAfterFiring = Symbol('_removeAfterFiring'); |
847 let _onPause = Symbol('_onPause'); | 847 let _onPause = Symbol('_onPause'); |
848 let _onResume = Symbol('_onResume'); | 848 let _onResume = Symbol('_onResume'); |
849 let _onCancel = Symbol('_onCancel'); | 849 let _onCancel = Symbol('_onCancel'); |
850 let _recordCancel = Symbol('_recordCancel'); | 850 let _recordCancel = Symbol('_recordCancel'); |
851 let _recordPause = Symbol('_recordPause'); | 851 let _recordPause = Symbol('_recordPause'); |
852 let _recordResume = Symbol('_recordResume'); | 852 let _recordResume = Symbol('_recordResume'); |
| 853 let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR'); |
853 let _zone = Symbol('_zone'); | 854 let _zone = Symbol('_zone'); |
854 let _state = Symbol('_state'); | 855 let _state = Symbol('_state'); |
855 let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR'); | |
856 let _onData = Symbol('_onData'); | 856 let _onData = Symbol('_onData'); |
857 let _onError = Symbol('_onError'); | 857 let _onError = Symbol('_onError'); |
858 let _onDone = Symbol('_onDone'); | 858 let _onDone = Symbol('_onDone'); |
859 let _cancelFuture = Symbol('_cancelFuture'); | 859 let _cancelFuture = Symbol('_cancelFuture'); |
860 let _pending = Symbol('_pending'); | 860 let _pending = Symbol('_pending'); |
861 let _setPendingEvents = Symbol('_setPendingEvents'); | 861 let _setPendingEvents = Symbol('_setPendingEvents'); |
862 let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING'); | 862 let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING'); |
863 let _extractPending = Symbol('_extractPending'); | 863 let _extractPending = Symbol('_extractPending'); |
864 let _isCanceled = Symbol('_isCanceled'); | 864 let _isCanceled = Symbol('_isCanceled'); |
865 let _isPaused = Symbol('_isPaused'); | 865 let _isPaused = Symbol('_isPaused'); |
(...skipping 781 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1647 return new _Future(); | 1647 return new _Future(); |
1648 } | 1648 } |
1649 } | 1649 } |
1650 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; | 1650 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
1651 return _DoneSubscription; | 1651 return _DoneSubscription; |
1652 }); | 1652 }); |
1653 let _DoneSubscription = _DoneSubscription$(); | 1653 let _DoneSubscription = _DoneSubscription$(); |
1654 class DeferredLibrary extends core.Object { | 1654 class DeferredLibrary extends core.Object { |
1655 DeferredLibrary(libraryName, opts) { | 1655 DeferredLibrary(libraryName, opts) { |
1656 let uri = opts && 'uri' in opts ? opts.uri : null; | 1656 let uri = opts && 'uri' in opts ? opts.uri : null; |
1657 this.libraryName = libraryName; | 1657 dart.initField(DeferredLibrary, this, 'libraryName', libraryName); |
1658 this.uri = uri; | 1658 dart.initField(DeferredLibrary, this, 'uri', uri); |
1659 } | 1659 } |
1660 load() { | 1660 load() { |
1661 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; | 1661 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; |
1662 } | 1662 } |
1663 } | 1663 } |
1664 let _s = Symbol('_s'); | 1664 let _s = Symbol('_s'); |
1665 class DeferredLoadException extends core.Object { | 1665 class DeferredLoadException extends core.Object { |
1666 DeferredLoadException(s) { | 1666 DeferredLoadException(s) { |
1667 this[_s] = s; | 1667 dart.initField(DeferredLoadException, this, _s, s); |
1668 } | 1668 } |
1669 toString() { | 1669 toString() { |
1670 return `DeferredLoadException: '${this[_s]}'`; | 1670 return `DeferredLoadException: '${this[_s]}'`; |
1671 } | 1671 } |
1672 } | 1672 } |
1673 DeferredLoadException[dart.implements] = () => [core.Exception]; | 1673 DeferredLoadException[dart.implements] = () => [core.Exception]; |
1674 let _completeWithValue = Symbol('_completeWithValue'); | 1674 let _completeWithValue = Symbol('_completeWithValue'); |
1675 let Future$ = dart.generic(function(T) { | 1675 let Future$ = dart.generic(function(T) { |
1676 class Future extends core.Object { | 1676 class Future extends core.Object { |
1677 Future(computation) { | 1677 Future(computation) { |
(...skipping 157 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1835 return new Future.value(null); | 1835 return new Future.value(null); |
1836 } | 1836 } |
1837 }); | 1837 }); |
1838 return Future; | 1838 return Future; |
1839 }); | 1839 }); |
1840 let Future = Future$(); | 1840 let Future = Future$(); |
1841 class TimeoutException extends core.Object { | 1841 class TimeoutException extends core.Object { |
1842 TimeoutException(message, duration) { | 1842 TimeoutException(message, duration) { |
1843 if (duration === void 0) | 1843 if (duration === void 0) |
1844 duration = null; | 1844 duration = null; |
1845 this.message = message; | 1845 dart.initField(TimeoutException, this, 'message', message); |
1846 this.duration = duration; | 1846 dart.initField(TimeoutException, this, 'duration', duration); |
1847 } | 1847 } |
1848 toString() { | 1848 toString() { |
1849 let result = "TimeoutException"; | 1849 let result = "TimeoutException"; |
1850 if (this.duration != null) | 1850 if (this.duration != null) |
1851 result = `TimeoutException after ${this.duration}`; | 1851 result = `TimeoutException after ${this.duration}`; |
1852 if (this.message != null) | 1852 if (this.message != null) |
1853 result = `${result}: ${this.message}`; | 1853 result = `${result}: ${this.message}`; |
1854 return result; | 1854 return result; |
1855 } | 1855 } |
1856 } | 1856 } |
(...skipping 1698 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3555 asFuture(futureValue) { | 3555 asFuture(futureValue) { |
3556 if (futureValue === void 0) | 3556 if (futureValue === void 0) |
3557 futureValue = null; | 3557 futureValue = null; |
3558 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); | 3558 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt
ream source subscription."); |
3559 } | 3559 } |
3560 } | 3560 } |
3561 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; | 3561 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; |
3562 return _BroadcastSubscriptionWrapper; | 3562 return _BroadcastSubscriptionWrapper; |
3563 }); | 3563 }); |
3564 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); | 3564 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); |
| 3565 let _STATE_FOUND = Symbol('_STATE_FOUND'); |
3565 let _current = Symbol('_current'); | 3566 let _current = Symbol('_current'); |
3566 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); | 3567 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); |
3567 let _STATE_FOUND = Symbol('_STATE_FOUND'); | |
3568 let _STATE_DONE = Symbol('_STATE_DONE'); | 3568 let _STATE_DONE = Symbol('_STATE_DONE'); |
3569 let _STATE_MOVING = Symbol('_STATE_MOVING'); | 3569 let _STATE_MOVING = Symbol('_STATE_MOVING'); |
3570 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); | 3570 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); |
3571 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); | 3571 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); |
3572 let _clear = Symbol('_clear'); | 3572 let _clear = Symbol('_clear'); |
3573 let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE'); | 3573 let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE'); |
3574 let _StreamIteratorImpl$ = dart.generic(function(T) { | 3574 let _StreamIteratorImpl$ = dart.generic(function(T) { |
3575 class _StreamIteratorImpl extends core.Object { | 3575 class _StreamIteratorImpl extends core.Object { |
3576 _StreamIteratorImpl(stream) { | 3576 _StreamIteratorImpl(stream) { |
3577 this[_subscription] = null; | 3577 this[_subscription] = null; |
(...skipping 1618 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5196 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5196 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5197 exports.CreateTimerHandler = CreateTimerHandler; | 5197 exports.CreateTimerHandler = CreateTimerHandler; |
5198 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5198 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5199 exports.PrintHandler = PrintHandler; | 5199 exports.PrintHandler = PrintHandler; |
5200 exports.ForkHandler = ForkHandler; | 5200 exports.ForkHandler = ForkHandler; |
5201 exports.ZoneSpecification = ZoneSpecification; | 5201 exports.ZoneSpecification = ZoneSpecification; |
5202 exports.ZoneDelegate = ZoneDelegate; | 5202 exports.ZoneDelegate = ZoneDelegate; |
5203 exports.Zone = Zone; | 5203 exports.Zone = Zone; |
5204 exports.runZoned = runZoned; | 5204 exports.runZoned = runZoned; |
5205 })(async || (async = {})); | 5205 })(async || (async = {})); |
OLD | NEW |