Index: lib/src/stream_sink_completer.dart |
diff --git a/lib/src/stream_sink_completer.dart b/lib/src/stream_sink_completer.dart |
index 00a7086cf978cba631c2f46fdb3dfaabde98eaf7..f8056c784fd73256bbe6d10c1b16cbb46296b721 100644 |
--- a/lib/src/stream_sink_completer.dart |
+++ b/lib/src/stream_sink_completer.dart |
@@ -36,9 +36,9 @@ class StreamSinkCompleter<T> { |
/// |
/// If the future completes with an error, the returned sink will instead |
/// be closed. Its [Sink.done] future will contain the error. |
- static StreamSink/*<T>*/ fromFuture/*<T>*/( |
- Future<StreamSink/*<T>*/> sinkFuture) { |
- var completer = new StreamSinkCompleter/*<T>*/(); |
+ static StreamSink<T> fromFuture<T>( |
+ Future<StreamSink<T>> sinkFuture) { |
+ var completer = new StreamSinkCompleter<T>(); |
sinkFuture.then(completer.setDestinationSink, |
onError: completer.setError); |
return completer.sink; |