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