| Index: tool/input_sdk/lib/async/stream_transformers.dart
|
| diff --git a/tool/input_sdk/lib/async/stream_transformers.dart b/tool/input_sdk/lib/async/stream_transformers.dart
|
| index b18d226fbe7cc238035a0205f0d76c34e61da123..e0982da4260ec621621a82b526aa21dac87f2be4 100644
|
| --- a/tool/input_sdk/lib/async/stream_transformers.dart
|
| +++ b/tool/input_sdk/lib/async/stream_transformers.dart
|
| @@ -28,7 +28,7 @@ class _EventSinkWrapper<T> implements EventSink<T> {
|
| class _SinkTransformerStreamSubscription<S, T>
|
| extends _BufferingStreamSubscription<T> {
|
| /// The transformer's input sink.
|
| - EventSink _transformerSink;
|
| + EventSink<S> _transformerSink;
|
|
|
| /// The subscription to the input stream.
|
| StreamSubscription<S> _subscription;
|
| @@ -183,8 +183,9 @@ class _BoundSinkStream<S, T> extends Stream<T> {
|
| void onDone(),
|
| bool cancelOnError }) {
|
| cancelOnError = identical(true, cancelOnError);
|
| - StreamSubscription<T> subscription = new _SinkTransformerStreamSubscription(
|
| - _stream, _sinkMapper, onData, onError, onDone, cancelOnError);
|
| + StreamSubscription<T> subscription =
|
| + new _SinkTransformerStreamSubscription<S, T>(
|
| + _stream, _sinkMapper, onData, onError, onDone, cancelOnError);
|
| return subscription;
|
| }
|
| }
|
| @@ -213,10 +214,11 @@ class _HandlerEventSink<S, T> implements EventSink<S> {
|
| _HandlerEventSink(this._handleData, this._handleError, this._handleDone,
|
| this._sink);
|
|
|
| - void add(S data) => _handleData(data, _sink);
|
| - void addError(Object error, [StackTrace stackTrace])
|
| - => _handleError(error, stackTrace, _sink);
|
| - void close() => _handleDone(_sink);
|
| + void add(S data) { _handleData(data, _sink); }
|
| + void addError(Object error, [StackTrace stackTrace]) {
|
| + _handleError(error, stackTrace, _sink);
|
| + }
|
| + void close() { _handleDone(_sink); }
|
| }
|
|
|
| /**
|
| @@ -250,7 +252,7 @@ class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {
|
| /** Default error handler forwards all errors. */
|
| static void _defaultHandleError(error, StackTrace stackTrace,
|
| EventSink sink) {
|
| - sink.addError(error);
|
| + sink.addError(error, stackTrace);
|
| }
|
|
|
| /** Default done handler forwards done. */
|
|
|