| 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..4219126817583657297af3d2af2cbce681385c16 100644
|
| --- a/lib/src/stream_sink_completer.dart
|
| +++ b/lib/src/stream_sink_completer.dart
|
| @@ -36,11 +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>*/();
|
| - sinkFuture.then(completer.setDestinationSink,
|
| - onError: completer.setError);
|
| + static StreamSink<T> fromFuture<T>(Future<StreamSink<T>> sinkFuture) {
|
| + var completer = new StreamSinkCompleter<T>();
|
| + sinkFuture.then(completer.setDestinationSink, onError: completer.setError);
|
| return completer.sink;
|
| }
|
|
|
|
|