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 902 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
913 } | 913 } |
914 [_extractPending]() { | 914 [_extractPending]() { |
915 dart.assert(this[_isCanceled]); | 915 dart.assert(this[_isCanceled]); |
916 let events = this[_pending]; | 916 let events = this[_pending]; |
917 this[_pending] = null; | 917 this[_pending] = null; |
918 return events; | 918 return events; |
919 } | 919 } |
920 onData(handleData) { | 920 onData(handleData) { |
921 if (handleData == null) | 921 if (handleData == null) |
922 handleData = dart.as(_nullDataHandler, dart.functionType(dart.void, [T
])); | 922 handleData = dart.as(_nullDataHandler, dart.functionType(dart.void, [T
])); |
923 this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _
DataHandler); | 923 this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _
DataHandler$(T)); |
924 } | 924 } |
925 onError(handleError) { | 925 onError(handleError) { |
926 if (handleError == null) | 926 if (handleError == null) |
927 handleError = _nullErrorHandler; | 927 handleError = _nullErrorHandler; |
928 this[_onError] = _registerErrorHandler(handleError, this[_zone]); | 928 this[_onError] = _registerErrorHandler(handleError, this[_zone]); |
929 } | 929 } |
930 onDone(handleDone) { | 930 onDone(handleDone) { |
931 if (handleDone == null) | 931 if (handleDone == null) |
932 handleDone = _nullDoneHandler; | 932 handleDone = _nullDoneHandler; |
933 this[_onDone] = this[_zone].registerCallback(handleDone); | 933 this[_onDone] = this[_zone].registerCallback(handleDone); |
(...skipping 3362 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4296 let handleError = opts && 'handleError' in opts ? opts.handleError : nul
l; | 4296 let handleError = opts && 'handleError' in opts ? opts.handleError : nul
l; |
4297 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; | 4297 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; |
4298 super._StreamSinkTransformer(dart.as(outputSink => { | 4298 super._StreamSinkTransformer(dart.as(outputSink => { |
4299 if (handleData == null) | 4299 if (handleData == null) |
4300 handleData = dart.as(_StreamHandlerTransformer[_defaultHandleData],
dart.functionType(dart.void, [S, EventSink$(T)])); | 4300 handleData = dart.as(_StreamHandlerTransformer[_defaultHandleData],
dart.functionType(dart.void, [S, EventSink$(T)])); |
4301 if (handleError == null) | 4301 if (handleError == null) |
4302 handleError = dart.as(_StreamHandlerTransformer[_defaultHandleError]
, dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)])); | 4302 handleError = dart.as(_StreamHandlerTransformer[_defaultHandleError]
, dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)])); |
4303 if (handleDone == null) | 4303 if (handleDone == null) |
4304 handleDone = _StreamHandlerTransformer[_defaultHandleDone]; | 4304 handleDone = _StreamHandlerTransformer[_defaultHandleDone]; |
4305 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); | 4305 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); |
4306 }, _SinkMapper)); | 4306 }, _SinkMapper$(S, T))); |
4307 } | 4307 } |
4308 bind(stream) { | 4308 bind(stream) { |
4309 return super.bind(stream); | 4309 return super.bind(stream); |
4310 } | 4310 } |
4311 static [_defaultHandleData](data, sink) { | 4311 static [_defaultHandleData](data, sink) { |
4312 sink.add(data); | 4312 sink.add(data); |
4313 } | 4313 } |
4314 static [_defaultHandleError](error, stackTrace, sink) { | 4314 static [_defaultHandleError](error, stackTrace, sink) { |
4315 sink.addError(error); | 4315 sink.addError(error); |
4316 } | 4316 } |
(...skipping 879 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 |