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