| 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(((__x66) => DEVC$RT.cast(__x66, DEVC$RT.type((__CastType64<T> _) { | 120 ) : super(((__x61) => DEVC$RT.cast(__x61, DEVC$RT.type((__CastType59<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: """, __x66 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) { | 124 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers.
dart: """, __x61 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) { |
| 125 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __CastType
70, DEVC$RT.type((__CastType67<S, T> _) { | 125 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __CastType
65, DEVC$RT.type((__CastType62<S, T> _) { |
| 126 } | 126 } |
| 127 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar
t: """, _defaultHandleData is __CastType67<S, T>, false); | 127 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar
t: """, _defaultHandleData is __CastType62<S, T>, false); |
| 128 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __Cast
Type77, DEVC$RT.type((__CastType73<T> _) { | 128 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __Cast
Type72, DEVC$RT.type((__CastType68<T> _) { |
| 129 } | 129 } |
| 130 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar
t: """, _defaultHandleError is __CastType73<T>, false); | 130 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar
t: """, _defaultHandleError is __CastType68<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 __CastType64<T>(EventSink<T> __u65); | 167 typedef dynamic __CastType59<T>(EventSink<T> __u60); |
| 168 typedef void __CastType67<S, T>(S __u68, EventSink<T> __u69); | 168 typedef void __CastType62<S, T>(S __u63, EventSink<T> __u64); |
| 169 typedef void __CastType70(dynamic __u71, EventSink<dynamic> __u72); | 169 typedef void __CastType65(dynamic __u66, EventSink<dynamic> __u67); |
| 170 typedef void __CastType73<T>(Object __u74, StackTrace __u75, EventSink<T> __u76
); | 170 typedef void __CastType68<T>(Object __u69, StackTrace __u70, EventSink<T> __u71
); |
| 171 typedef void __CastType77(dynamic __u78, StackTrace __u79, EventSink<dynamic> _
_u80); | 171 typedef void __CastType72(dynamic __u73, StackTrace __u74, EventSink<dynamic> _
_u75); |
| OLD | NEW |