Index: lib/src/delegate/stream_subscription.dart |
diff --git a/lib/src/delegate/stream_subscription.dart b/lib/src/delegate/stream_subscription.dart |
index 5fa7b01756a5559b6c804658c4e1f8e897399403..082341225f3a91686c5d91ba367ed9d325c257da 100644 |
--- a/lib/src/delegate/stream_subscription.dart |
+++ b/lib/src/delegate/stream_subscription.dart |
@@ -23,11 +23,11 @@ class DelegatingStreamSubscription<T> implements StreamSubscription<T> { |
/// regardless of its original generic type, by asserting that its events are |
/// instances of `T` whenever they're provided. If they're not, the |
/// subscription throws a [CastError]. |
- static StreamSubscription/*<T>*/ typed/*<T>*/( |
+ static StreamSubscription<T> typed<T>( |
StreamSubscription subscription) => |
- subscription is StreamSubscription/*<T>*/ |
+ subscription is StreamSubscription<T> |
? subscription |
- : new TypeSafeStreamSubscription/*<T>*/(subscription); |
+ : new TypeSafeStreamSubscription<T>(subscription); |
void onData(void handleData(T data)) { |
_source.onData(handleData); |
@@ -51,7 +51,7 @@ class DelegatingStreamSubscription<T> implements StreamSubscription<T> { |
Future cancel() => _source.cancel(); |
- Future/*<E>*/ asFuture/*<E>*/([/*=E*/ futureValue]) => |
+ Future<E> asFuture<E>([E futureValue]) => |
_source.asFuture(futureValue); |
bool get isPaused => _source.isPaused; |