| Index: test/stream_queue_test.dart
|
| diff --git a/test/stream_queue_test.dart b/test/stream_queue_test.dart
|
| index a41faf9f615b2a3ff8d641653694da6c8421a8fb..e5fe25cf4687e33119d29f26512c2d010732bddc 100644
|
| --- a/test/stream_queue_test.dart
|
| +++ b/test/stream_queue_test.dart
|
| @@ -37,7 +37,7 @@ main() {
|
| expect(controller.hasListener, isTrue);
|
| expect(controller.isPaused, isTrue);
|
|
|
| - var cancel = events.cancel();
|
| + events.cancel();
|
| expect(controller.hasListener, isFalse);
|
| });
|
| });
|
| @@ -283,6 +283,7 @@ main() {
|
| expect(() => events.take(1), throwsStateError);
|
| expect(() => events.rest, throwsStateError);
|
| expect(() => events.cancel(), throwsStateError);
|
| + expect(stream.toList(), completion([1, 2, 3, 4]));
|
| });
|
|
|
| test("forwards to underlying stream", () async {
|
| @@ -454,9 +455,9 @@ main() {
|
| test("- next after true, enqueued", () async {
|
| var events = new StreamQueue<int>(createStream());
|
| var responses = [];
|
| - var first = events.next.then(responses.add);
|
| - var hasSecond = events.hasNext.then(responses.add);
|
| - var second = events.next.then(responses.add);
|
| + events.next.then(responses.add);
|
| + events.hasNext.then(responses.add);
|
| + events.next.then(responses.add);
|
| do {
|
| await flushMicrotasks();
|
| } while (responses.length < 3);
|
|
|