| Index: lib/src/stream_sink_transformer.dart
|
| diff --git a/lib/src/stream_sink_transformer.dart b/lib/src/stream_sink_transformer.dart
|
| index d40bc4b76d84427dad35b3646a535af47b9e3203..cc1bdac77ffc2ab47661b7fac17b611f33911cc3 100644
|
| --- a/lib/src/stream_sink_transformer.dart
|
| +++ b/lib/src/stream_sink_transformer.dart
|
| @@ -24,8 +24,7 @@ abstract class StreamSinkTransformer<S, T> {
|
| /// This is equivalent to piping all events from the outer sink through a
|
| /// stream transformed by [transformer] and from there into the inner sink.
|
| const factory StreamSinkTransformer.fromStreamTransformer(
|
| - StreamTransformer<S, T> transformer) =
|
| - StreamTransformerWrapper<S, T>;
|
| + StreamTransformer<S, T> transformer) = StreamTransformerWrapper<S, T>;
|
|
|
| /// Creates a [StreamSinkTransformer] that delegates events to the given
|
| /// handlers.
|
| @@ -34,8 +33,8 @@ abstract class StreamSinkTransformer<S, T> {
|
| /// They're called for each incoming event, and any actions on the sink
|
| /// they're passed are forwarded to the inner sink. If a handler is omitted,
|
| /// the event is passed through unaltered.
|
| - factory StreamSinkTransformer.fromHandlers({
|
| - void handleData(S data, EventSink<T> sink),
|
| + factory StreamSinkTransformer.fromHandlers(
|
| + {void handleData(S data, EventSink<T> sink),
|
| void handleError(Object error, StackTrace stackTrace, EventSink<T> sink),
|
| void handleDone(EventSink<T> sink)}) {
|
| return new HandlerTransformer<S, T>(handleData, handleError, handleDone);
|
| @@ -54,9 +53,9 @@ abstract class StreamSinkTransformer<S, T> {
|
| /// This means that calls to [StreamSink.add] on the returned sink may throw a
|
| /// [CastError] if the argument type doesn't match the reified type of the
|
| /// sink.
|
| - static StreamSinkTransformer/*<S, T>*/ typed/*<S, T>*/(
|
| - StreamSinkTransformer transformer) =>
|
| - transformer is StreamSinkTransformer/*<S, T>*/
|
| + static StreamSinkTransformer<S, T>
|
| + typed<S, T>(StreamSinkTransformer transformer) => transformer
|
| + is StreamSinkTransformer<S, T>
|
| ? transformer
|
| : new TypeSafeStreamSinkTransformer(transformer);
|
| }
|
|
|