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 778 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
789 } | 789 } |
790 [_onListen](subscription) {} | 790 [_onListen](subscription) {} |
791 } | 791 } |
792 return _StreamImpl; | 792 return _StreamImpl; |
793 }); | 793 }); |
794 let _StreamImpl = _StreamImpl$(); | 794 let _StreamImpl = _StreamImpl$(); |
795 let _ControllerStream$ = dart.generic(function(T) { | 795 let _ControllerStream$ = dart.generic(function(T) { |
796 class _ControllerStream extends _StreamImpl$(T) { | 796 class _ControllerStream extends _StreamImpl$(T) { |
797 _ControllerStream(controller) { | 797 _ControllerStream(controller) { |
798 this[_controller] = controller; | 798 this[_controller] = controller; |
799 super._StreamImpl(); | |
800 } | 799 } |
801 [_createSubscription](onData, onError, onDone, cancelOnError) { | 800 [_createSubscription](onData, onError, onDone, cancelOnError) { |
802 return this[_controller][_subscribe](onData, onError, onDone, cancelOnEr
ror); | 801 return this[_controller][_subscribe](onData, onError, onDone, cancelOnEr
ror); |
803 } | 802 } |
804 get hashCode() { | 803 get hashCode() { |
805 return dart.notNull(this[_controller].hashCode) ^ 892482866; | 804 return dart.notNull(this[_controller].hashCode) ^ 892482866; |
806 } | 805 } |
807 ['=='](other) { | 806 ['=='](other) { |
808 if (core.identical(this, other)) | 807 if (core.identical(this, other)) |
809 return true; | 808 return true; |
(...skipping 2368 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3178 return _EventDispatch; | 3177 return _EventDispatch; |
3179 }); | 3178 }); |
3180 let _EventDispatch = _EventDispatch$(); | 3179 let _EventDispatch = _EventDispatch$(); |
3181 let _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType(
_PendingEvents, [])); | 3180 let _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType(
_PendingEvents, [])); |
3182 let _isUsed = Symbol('_isUsed'); | 3181 let _isUsed = Symbol('_isUsed'); |
3183 let _GeneratedStreamImpl$ = dart.generic(function(T) { | 3182 let _GeneratedStreamImpl$ = dart.generic(function(T) { |
3184 class _GeneratedStreamImpl extends _StreamImpl$(T) { | 3183 class _GeneratedStreamImpl extends _StreamImpl$(T) { |
3185 _GeneratedStreamImpl(pending) { | 3184 _GeneratedStreamImpl(pending) { |
3186 this[_pending] = pending; | 3185 this[_pending] = pending; |
3187 this[_isUsed] = false; | 3186 this[_isUsed] = false; |
3188 super._StreamImpl(); | |
3189 } | 3187 } |
3190 [_createSubscription](onData, onError, onDone, cancelOnError) { | 3188 [_createSubscription](onData, onError, onDone, cancelOnError) { |
3191 if (this[_isUsed]) | 3189 if (this[_isUsed]) |
3192 throw new core.StateError("Stream has already been listened to."); | 3190 throw new core.StateError("Stream has already been listened to."); |
3193 this[_isUsed] = true; | 3191 this[_isUsed] = true; |
3194 let _ = new _BufferingStreamSubscription(onData, onError, onDone, cancel
OnError); | 3192 let _ = new _BufferingStreamSubscription(onData, onError, onDone, cancel
OnError); |
3195 _[_setPendingEvents](this[_pending]()); | 3193 _[_setPendingEvents](this[_pending]()); |
3196 return _; | 3194 return _; |
3197 } | 3195 } |
3198 } | 3196 } |
(...skipping 2053 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5252 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5253 exports.CreateTimerHandler = CreateTimerHandler; | 5251 exports.CreateTimerHandler = CreateTimerHandler; |
5254 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5255 exports.PrintHandler = PrintHandler; | 5253 exports.PrintHandler = PrintHandler; |
5256 exports.ForkHandler = ForkHandler; | 5254 exports.ForkHandler = ForkHandler; |
5257 exports.ZoneSpecification = ZoneSpecification; | 5255 exports.ZoneSpecification = ZoneSpecification; |
5258 exports.ZoneDelegate = ZoneDelegate; | 5256 exports.ZoneDelegate = ZoneDelegate; |
5259 exports.Zone = Zone; | 5257 exports.Zone = Zone; |
5260 exports.runZoned = runZoned; | 5258 exports.runZoned = runZoned; |
5261 })(async || (async = {})); | 5259 })(async || (async = {})); |
OLD | NEW |