Change generic comment syntax to real generic syntax.

lib/src/delegate/stream_subscription.dart

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..e7575d8215cb0dcf6a582321f51e99447aec23d0 100644
--- a/lib/src/delegate/stream_subscription.dart
+++ b/lib/src/delegate/stream_subscription.dart
@@ -23,11 +23,10 @@ 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>*/(
-          StreamSubscription subscription) =>
-      subscription is StreamSubscription/*<T>*/
+  static StreamSubscription<T> typed<T>(StreamSubscription subscription) =>
+      subscription is StreamSubscription<T>
           ? subscription
-          : new TypeSafeStreamSubscription/*<T>*/(subscription);
+          : new TypeSafeStreamSubscription<T>(subscription);
 
   void onData(void handleData(T data)) {
     _source.onData(handleData);
@@ -51,8 +50,7 @@ class DelegatingStreamSubscription<T> implements StreamSubscription<T> {
 
   Future cancel() => _source.cancel();
 
-  Future/*<E>*/ asFuture/*<E>*/([/*=E*/ futureValue]) =>
-      _source.asFuture(futureValue);
+  Future<E> asFuture<E>([E futureValue]) => _source.asFuture(futureValue);
 
   bool get isPaused => _source.isPaused;
 }