Index: lib/src/subscription_stream.dart |
diff --git a/lib/src/subscription_stream.dart b/lib/src/subscription_stream.dart |
index c448620c5edc6a256aa5e72f50ffc7ad0c555555..50ca81b6e5110ffdca7244e4bbcf27e4cdf94bd2 100644 |
--- a/lib/src/subscription_stream.dart |
+++ b/lib/src/subscription_stream.dart |
@@ -68,7 +68,7 @@ class SubscriptionStream<T> extends Stream<T> { |
/// source subscription on the first error. |
class _CancelOnErrorSubscriptionWrapper<T> |
extends DelegatingStreamSubscription<T> { |
- _CancelOnErrorSubscriptionWrapper(StreamSubscription subscription) |
+ _CancelOnErrorSubscriptionWrapper(StreamSubscription<T> subscription) |
: super(subscription); |
void onError(Function handleError) { |