Index: lib/src/stream_queue.dart |
diff --git a/lib/src/stream_queue.dart b/lib/src/stream_queue.dart |
index 99e7436778a2e3d4963e8f0f7a290663f0833881..f5780817f6af973c1811022e80ccd798a02dfd6f 100644 |
--- a/lib/src/stream_queue.dart |
+++ b/lib/src/stream_queue.dart |
@@ -354,10 +354,10 @@ abstract class StreamQueue<T> { |
/// 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(); |
}); |