| Index: lib/src/stream_queue.dart
|
| diff --git a/lib/src/stream_queue.dart b/lib/src/stream_queue.dart
|
| index b9023ab91a9ff8279fd269e5b319fa2b0e20e6a4..1318114d8d7be84672e5ea62e400cd345f4470d1 100644
|
| --- a/lib/src/stream_queue.dart
|
| +++ b/lib/src/stream_queue.dart
|
| @@ -8,7 +8,7 @@ import 'dart:collection';
|
| import 'package:collection/collection.dart';
|
|
|
| import "cancelable_operation.dart";
|
| -import "result.dart";
|
| +import "result/result.dart";
|
| import "subscription_stream.dart";
|
| import "stream_completer.dart";
|
| import "stream_splitter.dart";
|
| @@ -859,9 +859,9 @@ class _LookAheadRequest<T> extends _ListRequest<T> {
|
| /// source subscription.
|
| class _CancelRequest<T> implements _EventRequest<T> {
|
| /// Completer for the future returned by the `cancel` call.
|
| + /// TODO(lrn); make this Completer<void> when that is implemented.
|
| final _completer = new Completer();
|
|
|
| - ///
|
| /// When the event is completed, it needs to cancel the active subscription
|
| /// of the `StreamQueue` object, if any.
|
| final StreamQueue _streamQueue;
|
|
|