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); |
} |