| Index: lib/src/stream_completer.dart
|
| diff --git a/lib/src/stream_completer.dart b/lib/src/stream_completer.dart
|
| index 73557b2acf1c9dc39d3414c932b99adedbb8226b..953985e387090eba8df812131ee5fac8cac485ac 100644
|
| --- a/lib/src/stream_completer.dart
|
| +++ b/lib/src/stream_completer.dart
|
| @@ -24,7 +24,7 @@ import "dart:async";
|
| /// the listen is performed directly on the source stream.
|
| class StreamCompleter<T> {
|
| /// The stream doing the actual work, is returned by [stream].
|
| - final _CompleterStream _stream = new _CompleterStream<T>();
|
| + final _stream = new _CompleterStream<T>();
|
|
|
| /// Convert a `Future<Stream>` to a `Stream`.
|
| ///
|
| @@ -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 fromFuture(Future<Stream> streamFuture) {
|
| - var completer = new StreamCompleter();
|
| + static Stream/*<T>*/ fromFuture/*<T>*/(Future<Stream/*<T>*/> streamFuture) {
|
| + var completer = new StreamCompleter/*<T>*/();
|
| streamFuture.then(completer.setSourceStream,
|
| onError: completer.setError);
|
| return completer.stream;
|
| @@ -109,13 +109,13 @@ class _CompleterStream<T> extends Stream<T> {
|
| ///
|
| /// Created if the user listens on this stream before the source stream
|
| /// is set, or if using [_setEmpty] so there is no source stream.
|
| - StreamController _controller;
|
| + StreamController<T> _controller;
|
|
|
| /// Source stream for the events provided by this stream.
|
| ///
|
| /// Set when the completer sets the source stream using [_setSourceStream]
|
| /// or [_setEmpty].
|
| - Stream _sourceStream;
|
| + Stream<T> _sourceStream;
|
|
|
| StreamSubscription<T> listen(onData(T data),
|
| {Function onError,
|
|
|