| 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 |