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