| 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 = new _SinkTransformerStreamSubscription(_st
ream, DEVC$RT.wrap((EventSink<S> f(EventSink<T> __u93)) { | 98 StreamSubscription<T> subscription = new _SinkTransformerStreamSubscription(_st
ream, DEVC$RT.cast(_sinkMapper, DEVC$RT.type((__t79<T, S> _) { |
| 99 EventSink<S> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dy
namic> _) { | |
| 100 } | 99 } |
| 101 ), DEVC$RT.type((EventSink<T> _) { | 100 ), __t77, "CompositeCast", """line 187, column 18 of dart:async/stream_transform
ers.dart: """, _sinkMapper is __t77, false), onData, onError, onDone, cancelOnEr
ror); |
| 102 } | |
| 103 ), "CastParam", """line 187, column 18 of dart:async/stream_transformers.dart: "
"", x0 is EventSink<T>, false)); | |
| 104 return f == null ? null : c; | |
| 105 } | |
| 106 , _sinkMapper, DEVC$RT.type((__t96<T, S> _) { | |
| 107 } | |
| 108 ), __t94, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart:
""", _sinkMapper is __t94), onData, onError, onDone, cancelOnError); | |
| 109 return subscription; | 101 return subscription; |
| 110 } | 102 } |
| 111 } | 103 } |
| 112 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); | 104 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); |
| 113 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve
ntSink<T> sink); | 105 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve
ntSink<T> sink); |
| 114 typedef void _TransformDoneHandler<T>(EventSink<T> sink); | 106 typedef void _TransformDoneHandler<T>(EventSink<T> sink); |
| 115 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand
ler<S, T> _handleData; | 107 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand
ler<S, T> _handleData; |
| 116 final _TransformErrorHandler<T> _handleError; | 108 final _TransformErrorHandler<T> _handleError; |
| 117 final _TransformDoneHandler<T> _handleDone; | 109 final _TransformDoneHandler<T> _handleDone; |
| 118 final EventSink<T> _sink; | 110 final EventSink<T> _sink; |
| 119 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._
sink); | 111 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._
sink); |
| 120 void add(S data) => _handleData(data, _sink); | 112 void add(S data) => _handleData(data, _sink); |
| 121 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta
ckTrace, _sink); | 113 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta
ckTrace, _sink); |
| 122 void close() => _handleDone(_sink); | 114 void close() => _handleDone(_sink); |
| 123 } | 115 } |
| 124 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St
reamHandlerTransformer({ | 116 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St
reamHandlerTransformer({ |
| 125 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack
Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)} | 117 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack
Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)} |
| 126 ) : super(((__x104) => DEVC$RT.wrap((dynamic f(EventSink<T> __u99)) { | 118 ) : super(((__x85) => DEVC$RT.cast(__x85, DEVC$RT.type((__t83<T> _) { |
| 127 dynamic c(EventSink<T> x0) => ((__x98) => DEVC$RT.cast(__x98, dynamic, DEVC$RT.t
ype((EventSink<S> _) { | |
| 128 } | 119 } |
| 129 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart:
""", __x98 is EventSink<S>, false))(f(x0)); | 120 ), DEVC$RT.type((__t81<T, S> _) { |
| 130 return f == null ? null : c; | |
| 131 } | 121 } |
| 132 , __x104, DEVC$RT.type((__t102<T> _) { | 122 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers.
dart: """, __x85 is __t81<T, S>, false))((EventSink<T> outputSink) { |
| 123 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __t89, DEV
C$RT.type((__t86<S, T> _) { |
| 133 } | 124 } |
| 134 ), DEVC$RT.type((__t100<T, S> _) { | 125 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar
t: """, _defaultHandleData is __t86<S, T>, false); |
| 126 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __t96,
DEVC$RT.type((__t92<T> _) { |
| 135 } | 127 } |
| 136 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart:
""", __x104 is __t100<T, S>))((EventSink<T> outputSink) { | 128 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar
t: """, _defaultHandleError is __t92<T>, false); |
| 137 if (handleData == null) handleData = DEVC$RT.wrap((void f(dynamic __u105, EventS
ink<dynamic> __u106)) { | |
| 138 void c(dynamic x0, EventSink<dynamic> x1) => f(x0, x1); | |
| 139 return f == null ? null : c; | |
| 140 } | |
| 141 , _defaultHandleData, __t110, DEVC$RT.type((__t107<S, T> _) { | |
| 142 } | |
| 143 ), "Wrap", """line 234, column 48 of dart:async/stream_transformers.dart: """, _
defaultHandleData is __t107<S, T>); | |
| 144 if (handleError == null) handleError = DEVC$RT.wrap((void f(dynamic __u113, Sta
ckTrace __u114, EventSink<dynamic> __u115)) { | |
| 145 void c(dynamic x0, StackTrace x1, EventSink<dynamic> x2) => f(x0, x1, x2); | |
| 146 return f == null ? null : c; | |
| 147 } | |
| 148 , _defaultHandleError, __t120, DEVC$RT.type((__t116<T> _) { | |
| 149 } | |
| 150 ), "Wrap", """line 235, column 50 of dart:async/stream_transformers.dart: """, _
defaultHandleError is __t116<T>); | |
| 151 if (handleDone == null) handleDone = _defaultHandleDone; | 129 if (handleDone == null) handleDone = _defaultHandleDone; |
| 152 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS
ink); | 130 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS
ink); |
| 153 } | 131 } |
| 154 )); | 132 )); |
| 155 Stream<T> bind(Stream<S> stream) { | 133 Stream<T> bind(Stream<S> stream) { |
| 156 return super.bind(stream); | 134 return super.bind(stream); |
| 157 } | 135 } |
| 158 static void _defaultHandleData(var data, EventSink sink) { | 136 static void _defaultHandleData(var data, EventSink sink) { |
| 159 sink.add(data); | 137 sink.add(data); |
| 160 } | 138 } |
| (...skipping 16 matching lines...) Expand all Loading... |
| 177 Function onError, void onDone(), bool cancelOnError} | 155 Function onError, void onDone(), bool cancelOnError} |
| 178 ) { | 156 ) { |
| 179 cancelOnError = identical(true, cancelOnError); | 157 cancelOnError = identical(true, cancelOnError); |
| 180 StreamSubscription<T> result = _transformer(_stream, cancelOnError); | 158 StreamSubscription<T> result = _transformer(_stream, cancelOnError); |
| 181 result.onData(onData); | 159 result.onData(onData); |
| 182 result.onError(onError); | 160 result.onError(onError); |
| 183 result.onDone(onDone); | 161 result.onDone(onDone); |
| 184 return result; | 162 return result; |
| 185 } | 163 } |
| 186 } | 164 } |
| 187 typedef EventSink<dynamic> __t94(EventSink<dynamic> __u95); | 165 typedef EventSink<dynamic> __t77(EventSink<dynamic> __u78); |
| 188 typedef EventSink<S> __t96<T, S>(EventSink<T> __u97); | 166 typedef EventSink<S> __t79<T, S>(EventSink<T> __u80); |
| 189 typedef EventSink<S> __t100<T, S>(EventSink<T> __u101); | 167 typedef EventSink<S> __t81<T, S>(EventSink<T> __u82); |
| 190 typedef dynamic __t102<T>(EventSink<T> __u103); | 168 typedef dynamic __t83<T>(EventSink<T> __u84); |
| 191 typedef void __t107<S, T>(S __u108, EventSink<T> __u109); | 169 typedef void __t86<S, T>(S __u87, EventSink<T> __u88); |
| 192 typedef void __t110(dynamic __u111, EventSink<dynamic> __u112); | 170 typedef void __t89(dynamic __u90, EventSink<dynamic> __u91); |
| 193 typedef void __t116<T>(Object __u117, StackTrace __u118, EventSink<T> __u119); | 171 typedef void __t92<T>(Object __u93, StackTrace __u94, EventSink<T> __u95); |
| 194 typedef void __t120(dynamic __u121, StackTrace __u122, EventSink<dynamic> __u12
3); | 172 typedef void __t96(dynamic __u97, StackTrace __u98, EventSink<dynamic> __u99); |
| OLD | NEW |