| 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 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 88 Stream<T> bind(Stream<S> stream) => new _BoundSinkStream<S, T>(stream, _sinkMap
per); | 88 Stream<T> bind(Stream<S> stream) => new _BoundSinkStream<S, T>(stream, _sinkMap
per); |
| 89 } | 89 } |
| 90 class _BoundSinkStream<S, T> extends Stream<T> {final _SinkMapper<S, T> _sinkMa
pper; | 90 class _BoundSinkStream<S, T> extends Stream<T> {final _SinkMapper<S, T> _sinkMa
pper; |
| 91 final Stream<S> _stream; | 91 final Stream<S> _stream; |
| 92 bool get isBroadcast => _stream.isBroadcast; | 92 bool get isBroadcast => _stream.isBroadcast; |
| 93 _BoundSinkStream(this._stream, this._sinkMapper); | 93 _BoundSinkStream(this._stream, this._sinkMapper); |
| 94 StreamSubscription<T> listen(void onData(T event), { | 94 StreamSubscription<T> listen(void onData(T event), { |
| 95 Function onError, void onDone(), bool cancelOnError} | 95 Function onError, void onDone(), bool cancelOnError} |
| 96 ) { | 96 ) { |
| 97 cancelOnError = identical(true, cancelOnError); | 97 cancelOnError = identical(true, cancelOnError); |
| 98 StreamSubscription<T> subscription = ((__x118) => DDC$RT.cast(__x118, DDC$RT.ty
pe((_SinkTransformerStreamSubscription<dynamic, dynamic> _) { | 98 StreamSubscription<T> subscription = ((__x123) => DDC$RT.cast(__x123, DDC$RT.ty
pe((_SinkTransformerStreamSubscription<dynamic, dynamic> _) { |
| 99 } | 99 } |
| 100 ), DDC$RT.type((StreamSubscription<T> _) { | 100 ), DDC$RT.type((StreamSubscription<T> _) { |
| 101 } | 101 } |
| 102 ), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: "
"", __x118 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript
ion(_stream, _sinkMapper, onData, onError, onDone, cancelOnError)); | 102 ), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: "
"", __x123 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript
ion(_stream, _sinkMapper, onData, onError, onDone, cancelOnError)); |
| 103 return subscription; | 103 return subscription; |
| 104 } | 104 } |
| 105 } | 105 } |
| 106 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); | 106 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); |
| 107 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve
ntSink<T> sink); | 107 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve
ntSink<T> sink); |
| 108 typedef void _TransformDoneHandler<T>(EventSink<T> sink); | 108 typedef void _TransformDoneHandler<T>(EventSink<T> sink); |
| 109 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand
ler<S, T> _handleData; | 109 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand
ler<S, T> _handleData; |
| 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(((__x125) => DDC$RT.wrap((dynamic f(EventSink<T> __u120)) { | 120 ) : super(((__x130) => DDC$RT.wrap((dynamic f(EventSink<T> __u125)) { |
| 121 dynamic c(EventSink<T> x0) => ((__x119) => DDC$RT.cast(__x119, dynamic, DDC$RT.t
ype((EventSink<S> _) { | 121 dynamic c(EventSink<T> x0) => ((__x124) => DDC$RT.cast(__x124, dynamic, DDC$RT.t
ype((EventSink<S> _) { |
| 122 } | 122 } |
| 123 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart:
""", __x119 is EventSink<S>, false))(f(x0)); | 123 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart:
""", __x124 is EventSink<S>, false))(f(x0)); |
| 124 return f == null ? null : c; | 124 return f == null ? null : c; |
| 125 } | 125 } |
| 126 , __x125, DDC$RT.type((__t123<T> _) { | 126 , __x130, DDC$RT.type((__t128<T> _) { |
| 127 } | 127 } |
| 128 ), DDC$RT.type((__t121<T, S> _) { | 128 ), DDC$RT.type((__t126<T, S> _) { |
| 129 } | 129 } |
| 130 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart:
""", __x125 is __t121<T, S>))((EventSink<T> outputSink) { | 130 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart:
""", __x130 is __t126<T, S>))((EventSink<T> outputSink) { |
| 131 if (handleData == null) handleData = _defaultHandleData; | 131 if (handleData == null) handleData = _defaultHandleData; |
| 132 if (handleError == null) handleError = _defaultHandleError; | 132 if (handleError == null) handleError = _defaultHandleError; |
| 133 if (handleDone == null) handleDone = _defaultHandleDone; | 133 if (handleDone == null) handleDone = _defaultHandleDone; |
| 134 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS
ink); | 134 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS
ink); |
| 135 } | 135 } |
| 136 )); | 136 )); |
| 137 Stream<T> bind(Stream<S> stream) { | 137 Stream<T> bind(Stream<S> stream) { |
| 138 return super.bind(stream); | 138 return super.bind(stream); |
| 139 } | 139 } |
| 140 static void _defaultHandleData(var data, EventSink sink) { | 140 static void _defaultHandleData(var data, EventSink sink) { |
| (...skipping 18 matching lines...) Expand all Loading... |
| 159 Function onError, void onDone(), bool cancelOnError} | 159 Function onError, void onDone(), bool cancelOnError} |
| 160 ) { | 160 ) { |
| 161 cancelOnError = identical(true, cancelOnError); | 161 cancelOnError = identical(true, cancelOnError); |
| 162 StreamSubscription<T> result = _transformer(_stream, cancelOnError); | 162 StreamSubscription<T> result = _transformer(_stream, cancelOnError); |
| 163 result.onData(onData); | 163 result.onData(onData); |
| 164 result.onError(onError); | 164 result.onError(onError); |
| 165 result.onDone(onDone); | 165 result.onDone(onDone); |
| 166 return result; | 166 return result; |
| 167 } | 167 } |
| 168 } | 168 } |
| 169 typedef EventSink<S> __t121<T, S>(EventSink<T> __u122); | 169 typedef EventSink<S> __t126<T, S>(EventSink<T> __u127); |
| 170 typedef dynamic __t123<T>(EventSink<T> __u124); | 170 typedef dynamic __t128<T>(EventSink<T> __u129); |
| OLD | NEW |