| Index: lib/src/stream_subscription_transformer.dart
|
| diff --git a/lib/src/stream_subscription_transformer.dart b/lib/src/stream_subscription_transformer.dart
|
| index c13341cc3774deee59a6ed526d4de840ab278b11..ad5453939b900dd1c12cda4266c005fcb5239a27 100644
|
| --- a/lib/src/stream_subscription_transformer.dart
|
| +++ b/lib/src/stream_subscription_transformer.dart
|
| @@ -27,10 +27,10 @@ typedef void _VoidHandler<T>(StreamSubscription<T> inner);
|
| /// synchronously call the corresponding method** on the inner
|
| /// [StreamSubscription]: [handleCancel] must call `cancel()`, [handlePause]
|
| /// must call `pause()`, and [handleResume] must call `resume()`.
|
| -StreamTransformer/*<T, T>*/ subscriptionTransformer/*<T>*/(
|
| - {Future handleCancel(StreamSubscription/*<T>*/ inner),
|
| - void handlePause(StreamSubscription/*<T>*/ inner),
|
| - void handleResume(StreamSubscription/*<T>*/ inner)}) {
|
| +StreamTransformer<T, T> subscriptionTransformer<T>(
|
| + {Future handleCancel(StreamSubscription<T> inner),
|
| + void handlePause(StreamSubscription<T> inner),
|
| + void handleResume(StreamSubscription<T> inner)}) {
|
| return new StreamTransformer((stream, cancelOnError) {
|
| return new _TransformedSubscription(
|
| stream.listen(null, cancelOnError: cancelOnError),
|
| @@ -99,6 +99,6 @@ class _TransformedSubscription<T> implements StreamSubscription<T> {
|
| _handleResume(_inner);
|
| }
|
|
|
| - Future/*<E>*/ asFuture/*<E>*/([/*=E*/ futureValue]) =>
|
| - _inner?.asFuture(futureValue) ?? new Completer/*<E>*/().future;
|
| + Future<E> asFuture<E>([E futureValue]) =>
|
| + _inner?.asFuture(futureValue) ?? new Completer<E>().future;
|
| }
|
|
|