Change generic comment syntax to real generic syntax.

lib/src/stream_queue.dart

 // Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:collection/collection.dart';
 
 import "cancelable_operation.dart";
@@ skipping 336 matching lines @@
   /// ```dart
   /// final _stdinQueue = new StreamQueue(stdin);
   ///
   /// /// Returns an operation that completes when the user sends a line to
   /// /// standard input.
   /// ///
   /// /// If the operation is canceled, stops waiting for user input.
   /// CancelableOperation<String> nextStdinLine() =>
   ///     _stdinQueue.cancelable((queue) => queue.next);
   /// ```
-  CancelableOperation/*<S>*/ cancelable/*<S>*/(
-      Future/*<S>*/ callback(StreamQueue<T> queue)) {
+  CancelableOperation<S> cancelable<S>(
+      Future<S> callback(StreamQueue<T> queue)) {
     var transaction = startTransaction();
-    var completer = new CancelableCompleter/*<S>*/(onCancel: () {
+    var completer = new CancelableCompleter<S>(onCancel: () {
       transaction.reject();
     });
 
     var queue = transaction.newQueue();
     completer.complete(callback(queue).whenComplete(() {
       if (!completer.isCanceled) transaction.commit(queue);
     }));
 
     return completer.operation;
   }
@@ skipping 609 matching lines @@
   }
 
   bool update(QueueList<Result<T>> events, bool isDone) {
     while (_eventsSent < events.length) {
       events[_eventsSent++].addTo(_controller);
     }
     if (isDone && !_controller.isClosed) _controller.close();
     return false;
   }
 }