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; |
} |