Index: lib/src/stream_sink_completer.dart |
diff --git a/lib/src/stream_sink_completer.dart b/lib/src/stream_sink_completer.dart |
index b53a8d2305f032a96c8f7322aa9c97c10811a059..00a7086cf978cba631c2f46fdb3dfaabde98eaf7 100644 |
--- a/lib/src/stream_sink_completer.dart |
+++ b/lib/src/stream_sink_completer.dart |
@@ -36,8 +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 fromFuture(Future<StreamSink> sinkFuture) { |
- var completer = new StreamSinkCompleter(); |
+ static StreamSink/*<T>*/ fromFuture/*<T>*/( |
+ Future<StreamSink/*<T>*/> sinkFuture) { |
+ var completer = new StreamSinkCompleter/*<T>*/(); |
sinkFuture.then(completer.setDestinationSink, |
onError: completer.setError); |
return completer.sink; |