| 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) { | 
|  |