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