Index: lib/src/stream_completer.dart |
diff --git a/lib/src/stream_completer.dart b/lib/src/stream_completer.dart |
index 953985e387090eba8df812131ee5fac8cac485ac..2bff6a5b9b26454d7b712bb5ff0d71d5d0e0bdcb 100644 |
--- a/lib/src/stream_completer.dart |
+++ b/lib/src/stream_completer.dart |
@@ -34,8 +34,8 @@ class StreamCompleter<T> { |
/// |
/// If the future completes with an error, the returned stream will |
/// instead contain just that error. |
- static Stream/*<T>*/ fromFuture/*<T>*/(Future<Stream/*<T>*/> streamFuture) { |
- var completer = new StreamCompleter/*<T>*/(); |
+ static Stream<T> fromFuture<T>(Future<Stream<T>> streamFuture) { |
+ var completer = new StreamCompleter<T>(); |
streamFuture.then(completer.setSourceStream, |
onError: completer.setError); |
return completer.stream; |