| Index: lib/src/lazy_stream.dart
|
| diff --git a/lib/src/lazy_stream.dart b/lib/src/lazy_stream.dart
|
| index 147fa8bd5f2984b66335bc4a78f8b9b8e2648a3b..8c8a9d8ecc5ee7a57da85b35309f98f3b074cff8 100644
|
| --- a/lib/src/lazy_stream.dart
|
| +++ b/lib/src/lazy_stream.dart
|
| @@ -27,9 +27,7 @@ class LazyStream<T> extends Stream<T> {
|
| }
|
|
|
| StreamSubscription<T> listen(void onData(T event),
|
| - {Function onError,
|
| - void onDone(),
|
| - bool cancelOnError}) {
|
| + {Function onError, void onDone(), bool cancelOnError}) {
|
| if (_callback == null) {
|
| throw new StateError("Stream has already been listened to.");
|
| }
|
| @@ -43,10 +41,10 @@ class LazyStream<T> extends Stream<T> {
|
| Stream<T> stream;
|
| if (result is Future) {
|
| stream = StreamCompleter.fromFuture(result.then((stream) {
|
| - return DelegatingStream.typed/*<T>*/(stream as Stream);
|
| + return DelegatingStream.typed<T>(stream as Stream);
|
| }));
|
| } else {
|
| - stream = DelegatingStream.typed/*<T>*/(result as Stream);
|
| + stream = DelegatingStream.typed<T>(result as Stream);
|
| }
|
|
|
| return stream.listen(onData,
|
|
|