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 } |
(...skipping 1042 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1053 } | 1053 } |
1054 } | 1054 } |
1055 [_close]() { | 1055 [_close]() { |
1056 dart.assert(!dart.notNull(this[_isClosed])); | 1056 dart.assert(!dart.notNull(this[_isClosed])); |
1057 if (this[_isCanceled]) | 1057 if (this[_isCanceled]) |
1058 return; | 1058 return; |
1059 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStrea
mSubscription[_STATE_CLOSED]); | 1059 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStrea
mSubscription[_STATE_CLOSED]); |
1060 if (this[_canFire]) { | 1060 if (this[_canFire]) { |
1061 this[_sendDone](); | 1061 this[_sendDone](); |
1062 } else { | 1062 } else { |
1063 this[_addPending](new _DelayedDone()); | 1063 this[_addPending](dart.const(new _DelayedDone())); |
1064 } | 1064 } |
1065 } | 1065 } |
1066 [_onPause]() { | 1066 [_onPause]() { |
1067 dart.assert(this[_isInputPaused]); | 1067 dart.assert(this[_isInputPaused]); |
1068 } | 1068 } |
1069 [_onResume]() { | 1069 [_onResume]() { |
1070 dart.assert(!dart.notNull(this[_isInputPaused])); | 1070 dart.assert(!dart.notNull(this[_isInputPaused])); |
1071 } | 1071 } |
1072 [_onCancel]() { | 1072 [_onCancel]() { |
1073 dart.assert(this[_isCanceled]); | 1073 dart.assert(this[_isCanceled]); |
(...skipping 455 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1529 [_sendError](error, stackTrace) { | 1529 [_sendError](error, stackTrace) { |
1530 for (let link = this[_next]; !dart.notNull(core.identical(link, this));
link = link[_next]) { | 1530 for (let link = this[_next]; !dart.notNull(core.identical(link, this));
link = link[_next]) { |
1531 let subscription = dart.as(link, _BroadcastSubscription$(T)); | 1531 let subscription = dart.as(link, _BroadcastSubscription$(T)); |
1532 subscription[_addPending](new _DelayedError(error, stackTrace)); | 1532 subscription[_addPending](new _DelayedError(error, stackTrace)); |
1533 } | 1533 } |
1534 } | 1534 } |
1535 [_sendDone]() { | 1535 [_sendDone]() { |
1536 if (!dart.notNull(this[_isEmpty])) { | 1536 if (!dart.notNull(this[_isEmpty])) { |
1537 for (let link = this[_next]; !dart.notNull(core.identical(link, this))
; link = link[_next]) { | 1537 for (let link = this[_next]; !dart.notNull(core.identical(link, this))
; link = link[_next]) { |
1538 let subscription = dart.as(link, _BroadcastSubscription$(T)); | 1538 let subscription = dart.as(link, _BroadcastSubscription$(T)); |
1539 subscription[_addPending](new _DelayedDone()); | 1539 subscription[_addPending](dart.const(new _DelayedDone())); |
1540 } | 1540 } |
1541 } else { | 1541 } else { |
1542 dart.assert(this[_doneFuture] != null); | 1542 dart.assert(this[_doneFuture] != null); |
1543 dart.assert(this[_doneFuture][_mayComplete]); | 1543 dart.assert(this[_doneFuture][_mayComplete]); |
1544 this[_doneFuture][_asyncComplete](null); | 1544 this[_doneFuture][_asyncComplete](null); |
1545 } | 1545 } |
1546 } | 1546 } |
1547 } | 1547 } |
1548 return _AsyncBroadcastStreamController; | 1548 return _AsyncBroadcastStreamController; |
1549 }); | 1549 }); |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1583 } | 1583 } |
1584 if (!dart.notNull(this[_mayAddEvent])) | 1584 if (!dart.notNull(this[_mayAddEvent])) |
1585 throw this[_addEventError](); | 1585 throw this[_addEventError](); |
1586 this[_sendError](error, stackTrace); | 1586 this[_sendError](error, stackTrace); |
1587 while (this[_hasPending]) { | 1587 while (this[_hasPending]) { |
1588 this[_pending].handleNext(this); | 1588 this[_pending].handleNext(this); |
1589 } | 1589 } |
1590 } | 1590 } |
1591 close() { | 1591 close() { |
1592 if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) { | 1592 if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) { |
1593 this[_addPendingEvent](new _DelayedDone()); | 1593 this[_addPendingEvent](dart.const(new _DelayedDone())); |
1594 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr
eamController[_STATE_CLOSED]); | 1594 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr
eamController[_STATE_CLOSED]); |
1595 return super.done; | 1595 return super.done; |
1596 } | 1596 } |
1597 let result = super.close(); | 1597 let result = super.close(); |
1598 dart.assert(!dart.notNull(this[_hasPending])); | 1598 dart.assert(!dart.notNull(this[_hasPending])); |
1599 return result; | 1599 return result; |
1600 } | 1600 } |
1601 [_callOnCancel]() { | 1601 [_callOnCancel]() { |
1602 if (this[_hasPending]) { | 1602 if (this[_hasPending]) { |
1603 this[_pending].clear(); | 1603 this[_pending].clear(); |
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1796 dart.dcall(cleanUp, value); | 1796 dart.dcall(cleanUp, value); |
1797 }); | 1797 }); |
1798 } | 1798 } |
1799 if (remaining == 0 && !dart.notNull(eagerError)) { | 1799 if (remaining == 0 && !dart.notNull(eagerError)) { |
1800 result[_completeError](error, stackTrace); | 1800 result[_completeError](error, stackTrace); |
1801 } | 1801 } |
1802 } | 1802 } |
1803 }, {onError: handleError}); | 1803 }, {onError: handleError}); |
1804 } | 1804 } |
1805 if (remaining == 0) { | 1805 if (remaining == 0) { |
1806 return new Future$(core.List).value(/* Unimplemented const */[]); | 1806 return new Future$(core.List).value(dart.const([])); |
1807 } | 1807 } |
1808 values = new core.List(remaining); | 1808 values = new core.List(remaining); |
1809 return result; | 1809 return result; |
1810 } | 1810 } |
1811 static forEach(input, f) { | 1811 static forEach(input, f) { |
1812 let iterator = input[core.$iterator]; | 1812 let iterator = input[core.$iterator]; |
1813 return Future.doWhile(() => { | 1813 return Future.doWhile(() => { |
1814 if (!dart.notNull(iterator.moveNext())) | 1814 if (!dart.notNull(iterator.moveNext())) |
1815 return false; | 1815 return false; |
1816 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ =
> true); | 1816 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ =
> true); |
(...skipping 1072 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2889 if (!dart.notNull(this[_mayAddEvent])) | 2889 if (!dart.notNull(this[_mayAddEvent])) |
2890 throw this[_badEventState](); | 2890 throw this[_badEventState](); |
2891 this[_closeUnchecked](); | 2891 this[_closeUnchecked](); |
2892 return this[_ensureDoneFuture](); | 2892 return this[_ensureDoneFuture](); |
2893 } | 2893 } |
2894 [_closeUnchecked]() { | 2894 [_closeUnchecked]() { |
2895 this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamControll
er[_STATE_CLOSED]); | 2895 this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamControll
er[_STATE_CLOSED]); |
2896 if (this.hasListener) { | 2896 if (this.hasListener) { |
2897 this[_sendDone](); | 2897 this[_sendDone](); |
2898 } else if (this[_isInitialState]) { | 2898 } else if (this[_isInitialState]) { |
2899 this[_ensurePendingEvents]().add(new _DelayedDone()); | 2899 this[_ensurePendingEvents]().add(dart.const(new _DelayedDone())); |
2900 } | 2900 } |
2901 } | 2901 } |
2902 [_add](value) { | 2902 [_add](value) { |
2903 if (this.hasListener) { | 2903 if (this.hasListener) { |
2904 this[_sendData](value); | 2904 this[_sendData](value); |
2905 } else if (this[_isInitialState]) { | 2905 } else if (this[_isInitialState]) { |
2906 this[_ensurePendingEvents]().add(new (_DelayedData$(T))(value)); | 2906 this[_ensurePendingEvents]().add(new (_DelayedData$(T))(value)); |
2907 } | 2907 } |
2908 } | 2908 } |
2909 [_addError](error, stackTrace) { | 2909 [_addError](error, stackTrace) { |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3018 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(); | 3018 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(); |
3019 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { | 3019 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { |
3020 class _AsyncStreamControllerDispatch extends core.Object { | 3020 class _AsyncStreamControllerDispatch extends core.Object { |
3021 [_sendData](data) { | 3021 [_sendData](data) { |
3022 this[_subscription][_addPending](new _DelayedData(data)); | 3022 this[_subscription][_addPending](new _DelayedData(data)); |
3023 } | 3023 } |
3024 [_sendError](error, stackTrace) { | 3024 [_sendError](error, stackTrace) { |
3025 this[_subscription][_addPending](new _DelayedError(error, stackTrace)); | 3025 this[_subscription][_addPending](new _DelayedError(error, stackTrace)); |
3026 } | 3026 } |
3027 [_sendDone]() { | 3027 [_sendDone]() { |
3028 this[_subscription][_addPending](new _DelayedDone()); | 3028 this[_subscription][_addPending](dart.const(new _DelayedDone())); |
3029 } | 3029 } |
3030 } | 3030 } |
3031 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(
T)]; | 3031 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(
T)]; |
3032 return _AsyncStreamControllerDispatch; | 3032 return _AsyncStreamControllerDispatch; |
3033 }); | 3033 }); |
3034 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(); | 3034 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(); |
3035 let _AsyncStreamController$ = dart.generic(function(T) { | 3035 let _AsyncStreamController$ = dart.generic(function(T) { |
3036 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { | 3036 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { |
3037 _AsyncStreamController(onListen, onPause, onResume, onCancel) { | 3037 _AsyncStreamController(onListen, onPause, onResume, onCancel) { |
3038 this[_onListen] = onListen; | 3038 this[_onListen] = onListen; |
(...skipping 1869 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4908 _internal.printToConsole(line); | 4908 _internal.printToConsole(line); |
4909 } | 4909 } |
4910 // Function _printToZone: (String) → void | 4910 // Function _printToZone: (String) → void |
4911 function _printToZone(line) { | 4911 function _printToZone(line) { |
4912 Zone.current.print(line); | 4912 Zone.current.print(line); |
4913 } | 4913 } |
4914 // Function _rootFork: (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynam
ic, dynamic>) → Zone | 4914 // Function _rootFork: (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynam
ic, dynamic>) → Zone |
4915 function _rootFork(self, parent, zone, specification, zoneValues) { | 4915 function _rootFork(self, parent, zone, specification, zoneValues) { |
4916 _internal.printToZone = _printToZone; | 4916 _internal.printToZone = _printToZone; |
4917 if (specification == null) { | 4917 if (specification == null) { |
4918 specification = new ZoneSpecification(); | 4918 specification = dart.const(new ZoneSpecification()); |
4919 } else if (!dart.is(specification, _ZoneSpecification)) { | 4919 } else if (!dart.is(specification, _ZoneSpecification)) { |
4920 throw new core.ArgumentError("ZoneSpecifications must be instantiated" + "
with the provided constructor."); | 4920 throw new core.ArgumentError("ZoneSpecifications must be instantiated" + "
with the provided constructor."); |
4921 } | 4921 } |
4922 let valueMap = null; | 4922 let valueMap = null; |
4923 if (zoneValues == null) { | 4923 if (zoneValues == null) { |
4924 if (dart.is(zone, _Zone)) { | 4924 if (dart.is(zone, _Zone)) { |
4925 valueMap = zone[_map]; | 4925 valueMap = zone[_map]; |
4926 } else { | 4926 } else { |
4927 valueMap = new collection.HashMap(); | 4927 valueMap = new collection.HashMap(); |
4928 } | 4928 } |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4973 } | 4973 } |
4974 } | 4974 } |
4975 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; | 4975 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
4976 let _rootMap = Symbol('_rootMap'); | 4976 let _rootMap = Symbol('_rootMap'); |
4977 let _rootDelegate = Symbol('_rootDelegate'); | 4977 let _rootDelegate = Symbol('_rootDelegate'); |
4978 class _RootZone extends _Zone { | 4978 class _RootZone extends _Zone { |
4979 _RootZone() { | 4979 _RootZone() { |
4980 super._Zone(); | 4980 super._Zone(); |
4981 } | 4981 } |
4982 get [_run]() { | 4982 get [_run]() { |
4983 return new _ZoneFunction(_ROOT_ZONE, _rootRun); | 4983 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun)); |
4984 } | 4984 } |
4985 get [_runUnary]() { | 4985 get [_runUnary]() { |
4986 return new _ZoneFunction(_ROOT_ZONE, _rootRunUnary); | 4986 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary)); |
4987 } | 4987 } |
4988 get [_runBinary]() { | 4988 get [_runBinary]() { |
4989 return new _ZoneFunction(_ROOT_ZONE, _rootRunBinary); | 4989 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary)); |
4990 } | 4990 } |
4991 get [_registerCallback]() { | 4991 get [_registerCallback]() { |
4992 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback); | 4992 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback)); |
4993 } | 4993 } |
4994 get [_registerUnaryCallback]() { | 4994 get [_registerUnaryCallback]() { |
4995 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback); | 4995 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback
)); |
4996 } | 4996 } |
4997 get [_registerBinaryCallback]() { | 4997 get [_registerBinaryCallback]() { |
4998 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback); | 4998 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallbac
k)); |
4999 } | 4999 } |
5000 get [_errorCallback]() { | 5000 get [_errorCallback]() { |
5001 return new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback); | 5001 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback)); |
5002 } | 5002 } |
5003 get [_scheduleMicrotask]() { | 5003 get [_scheduleMicrotask]() { |
5004 return new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask); | 5004 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask)); |
5005 } | 5005 } |
5006 get [_createTimer]() { | 5006 get [_createTimer]() { |
5007 return new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer); | 5007 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer)); |
5008 } | 5008 } |
5009 get [_createPeriodicTimer]() { | 5009 get [_createPeriodicTimer]() { |
5010 return new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer); | 5010 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer))
; |
5011 } | 5011 } |
5012 get [_print]() { | 5012 get [_print]() { |
5013 return new _ZoneFunction(_ROOT_ZONE, _rootPrint); | 5013 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint)); |
5014 } | 5014 } |
5015 get [_fork]() { | 5015 get [_fork]() { |
5016 return new _ZoneFunction(_ROOT_ZONE, _rootFork); | 5016 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork)); |
5017 } | 5017 } |
5018 get [_handleUncaughtError]() { | 5018 get [_handleUncaughtError]() { |
5019 return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError); | 5019 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError))
; |
5020 } | 5020 } |
5021 get parent() { | 5021 get parent() { |
5022 return null; | 5022 return null; |
5023 } | 5023 } |
5024 get [_map]() { | 5024 get [_map]() { |
5025 return _RootZone[_rootMap]; | 5025 return _RootZone[_rootMap]; |
5026 } | 5026 } |
5027 get [_delegate]() { | 5027 get [_delegate]() { |
5028 if (_RootZone[_rootDelegate] != null) | 5028 if (_RootZone[_rootDelegate] != null) |
5029 return _RootZone[_rootDelegate]; | 5029 return _RootZone[_rootDelegate]; |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5143 _internal.printToConsole(line); | 5143 _internal.printToConsole(line); |
5144 } | 5144 } |
5145 } | 5145 } |
5146 _RootZone._rootDelegate = null; | 5146 _RootZone._rootDelegate = null; |
5147 dart.defineLazyProperties(_RootZone, { | 5147 dart.defineLazyProperties(_RootZone, { |
5148 get _rootMap() { | 5148 get _rootMap() { |
5149 return new collection.HashMap(); | 5149 return new collection.HashMap(); |
5150 }, | 5150 }, |
5151 set _rootMap(_) {} | 5151 set _rootMap(_) {} |
5152 }); | 5152 }); |
5153 let _ROOT_ZONE = new _RootZone(); | 5153 let _ROOT_ZONE = dart.const(new _RootZone()); |
5154 // Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneS
pecification: ZoneSpecification, onError: Function}) → dynamic | 5154 // Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneS
pecification: ZoneSpecification, onError: Function}) → dynamic |
5155 function runZoned(body, opts) { | 5155 function runZoned(body, opts) { |
5156 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; | 5156 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; |
5157 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; | 5157 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci
fication : null; |
5158 let onError = opts && 'onError' in opts ? opts.onError : null; | 5158 let onError = opts && 'onError' in opts ? opts.onError : null; |
5159 let errorHandler = null; | 5159 let errorHandler = null; |
5160 if (onError != null) { | 5160 if (onError != null) { |
5161 errorHandler = (self, parent, zone, error, stackTrace) => { | 5161 errorHandler = (self, parent, zone, error, stackTrace) => { |
5162 try { | 5162 try { |
5163 if (dart.is(onError, ZoneBinaryCallback)) { | 5163 if (dart.is(onError, ZoneBinaryCallback)) { |
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5251 exports.CreateTimerHandler = CreateTimerHandler; | 5251 exports.CreateTimerHandler = CreateTimerHandler; |
5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5253 exports.PrintHandler = PrintHandler; | 5253 exports.PrintHandler = PrintHandler; |
5254 exports.ForkHandler = ForkHandler; | 5254 exports.ForkHandler = ForkHandler; |
5255 exports.ZoneSpecification = ZoneSpecification; | 5255 exports.ZoneSpecification = ZoneSpecification; |
5256 exports.ZoneDelegate = ZoneDelegate; | 5256 exports.ZoneDelegate = ZoneDelegate; |
5257 exports.Zone = Zone; | 5257 exports.Zone = Zone; |
5258 exports.runZoned = runZoned; | 5258 exports.runZoned = runZoned; |
5259 })(async || (async = {})); | 5259 })(async || (async = {})); |
OLD | NEW |