| Index: lib/src/stream_queue.dart
|
| diff --git a/lib/src/stream_queue.dart b/lib/src/stream_queue.dart
|
| index 14eb7a0a66f6b29e48b2da2bed9010c235561fd4..217032656492dcece2f641810b94748647e0d67b 100644
|
| --- a/lib/src/stream_queue.dart
|
| +++ b/lib/src/stream_queue.dart
|
| @@ -353,10 +353,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();
|
| });
|
|
|
|
|