| OLD | NEW |
| 1 part of dart.async; | 1 part of dart.async; |
| 2 class _EventSinkWrapper<T> implements EventSink<T> {_EventSink _sink; | 2 class _EventSinkWrapper<T> implements EventSink<T> {_EventSink _sink; |
| 3 _EventSinkWrapper(this._sink); | 3 _EventSinkWrapper(this._sink); |
| 4 void add(T data) { | 4 void add(T data) { |
| 5 _sink._add(data); | 5 _sink._add(data); |
| 6 } | 6 } |
| 7 void addError(error, [StackTrace stackTrace]) { | 7 void addError(error, [StackTrace stackTrace]) { |
| 8 _sink._addError(error, stackTrace); | 8 _sink._addError(error, stackTrace); |
| 9 } | 9 } |
| 10 void close() { | 10 void close() { |
| (...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 110 final _TransformErrorHandler<T> _handleError; | 110 final _TransformErrorHandler<T> _handleError; |
| 111 final _TransformDoneHandler<T> _handleDone; | 111 final _TransformDoneHandler<T> _handleDone; |
| 112 final EventSink<T> _sink; | 112 final EventSink<T> _sink; |
| 113 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._
sink); | 113 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._
sink); |
| 114 void add(S data) => _handleData(data, _sink); | 114 void add(S data) => _handleData(data, _sink); |
| 115 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta
ckTrace, _sink); | 115 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta
ckTrace, _sink); |
| 116 void close() => _handleDone(_sink); | 116 void close() => _handleDone(_sink); |
| 117 } | 117 } |
| 118 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St
reamHandlerTransformer({ | 118 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St
reamHandlerTransformer({ |
| 119 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack
Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)} | 119 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack
Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)} |
| 120 ) : super(((__x64) => DEVC$RT.cast(__x64, DEVC$RT.type((__t62<T> _) { | 120 ) : super(((__x64) => DEVC$RT.cast(__x64, DEVC$RT.type((__CastType62<T> _) { |
| 121 } | 121 } |
| 122 ), DEVC$RT.type((_SinkMapper<S, T> _) { | 122 ), DEVC$RT.type((_SinkMapper<S, T> _) { |
| 123 } | 123 } |
| 124 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers.
dart: """, __x64 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) { | 124 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers.
dart: """, __x64 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) { |
| 125 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __t68, DEV
C$RT.type((__t65<S, T> _) { | 125 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __CastType
68, DEVC$RT.type((__CastType65<S, T> _) { |
| 126 } | 126 } |
| 127 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar
t: """, _defaultHandleData is __t65<S, T>, false); | 127 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar
t: """, _defaultHandleData is __CastType65<S, T>, false); |
| 128 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __t75,
DEVC$RT.type((__t71<T> _) { | 128 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __Cast
Type75, DEVC$RT.type((__CastType71<T> _) { |
| 129 } | 129 } |
| 130 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar
t: """, _defaultHandleError is __t71<T>, false); | 130 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar
t: """, _defaultHandleError is __CastType71<T>, false); |
| 131 if (handleDone == null) handleDone = _defaultHandleDone; | 131 if (handleDone == null) handleDone = _defaultHandleDone; |
| 132 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS
ink); | 132 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS
ink); |
| 133 } | 133 } |
| 134 )); | 134 )); |
| 135 Stream<T> bind(Stream<S> stream) { | 135 Stream<T> bind(Stream<S> stream) { |
| 136 return super.bind(stream); | 136 return super.bind(stream); |
| 137 } | 137 } |
| 138 static void _defaultHandleData(var data, EventSink sink) { | 138 static void _defaultHandleData(var data, EventSink sink) { |
| 139 sink.add(data); | 139 sink.add(data); |
| 140 } | 140 } |
| (...skipping 16 matching lines...) Expand all Loading... |
| 157 Function onError, void onDone(), bool cancelOnError} | 157 Function onError, void onDone(), bool cancelOnError} |
| 158 ) { | 158 ) { |
| 159 cancelOnError = identical(true, cancelOnError); | 159 cancelOnError = identical(true, cancelOnError); |
| 160 StreamSubscription<T> result = _transformer(_stream, cancelOnError); | 160 StreamSubscription<T> result = _transformer(_stream, cancelOnError); |
| 161 result.onData(onData); | 161 result.onData(onData); |
| 162 result.onError(onError); | 162 result.onError(onError); |
| 163 result.onDone(onDone); | 163 result.onDone(onDone); |
| 164 return result; | 164 return result; |
| 165 } | 165 } |
| 166 } | 166 } |
| 167 typedef dynamic __t62<T>(EventSink<T> __u63); | 167 typedef dynamic __CastType62<T>(EventSink<T> __u63); |
| 168 typedef void __t65<S, T>(S __u66, EventSink<T> __u67); | 168 typedef void __CastType65<S, T>(S __u66, EventSink<T> __u67); |
| 169 typedef void __t68(dynamic __u69, EventSink<dynamic> __u70); | 169 typedef void __CastType68(dynamic __u69, EventSink<dynamic> __u70); |
| 170 typedef void __t71<T>(Object __u72, StackTrace __u73, EventSink<T> __u74); | 170 typedef void __CastType71<T>(Object __u72, StackTrace __u73, EventSink<T> __u74
); |
| 171 typedef void __t75(dynamic __u76, StackTrace __u77, EventSink<dynamic> __u78); | 171 typedef void __CastType75(dynamic __u76, StackTrace __u77, EventSink<dynamic> _
_u78); |
| OLD | NEW |