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 |