OLD | NEW |
1 // Copyright (c) 2017, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2017, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 import "dart:async"; | 5 import "dart:async"; |
6 import "dart:typed_data"; | 6 import "dart:typed_data"; |
7 | 7 |
8 import "package:test/test.dart"; | 8 import "package:test/test.dart"; |
9 import "package:async/async.dart" show byteCollector, collectBytes, Result; | 9 import "package:async/async.dart"; |
10 | 10 |
11 void main() { | 11 void main() { |
12 group("collectBytes", () { | 12 group("collectBytes", () { |
13 test("simple list and overflow", () { | 13 test("simple list and overflow", () { |
14 var result = collectBytes(new Stream.fromIterable([ | 14 var result = collectBytes(new Stream.fromIterable([ |
15 [0], | 15 [0], |
16 [1], | 16 [1], |
17 [2], | 17 [2], |
18 [256] | 18 [256] |
19 ])); | 19 ])); |
20 expect(result, completion([0, 1, 2, 0])); | 20 expect(result, completion([0, 1, 2, 0])); |
21 }); | 21 }); |
22 | 22 |
23 test("no events", () { | 23 test("no events", () { |
24 var result = collectBytes(new Stream.fromIterable([])); | 24 var result = collectBytes(new Stream.fromIterable([])); |
25 expect(result, completion([])); | 25 expect(result, completion([])); |
26 }); | 26 }); |
27 | 27 |
28 test("empty events", () { | 28 test("empty events", () { |
29 var result = collectBytes(new Stream.fromIterable([[], []])); | 29 var result = collectBytes(new Stream.fromIterable([[], []])); |
30 expect(result, completion([])); | 30 expect(result, completion([])); |
31 }); | 31 }); |
32 | 32 |
33 test("error event", () { | 33 test("error event", () { |
34 var result = collectBytes(new Stream.fromIterable( | 34 var result = collectBytes(new Stream.fromIterable( |
35 new Iterable.generate(3, (n) => n == 2 ? throw "badness" : [n]))); | 35 new Iterable.generate(3, (n) => n == 2 ? throw "badness" : [n]))); |
36 expect(result, throwsA("badness")); | 36 expect(result, throwsA("badness")); |
37 }); | 37 }); |
38 }); | 38 }); |
| 39 |
| 40 group("collectBytes", () { |
| 41 test("simple list and overflow", () { |
| 42 var result = collectBytesCancelable(new Stream.fromIterable([ |
| 43 [0], |
| 44 [1], |
| 45 [2], |
| 46 [256] |
| 47 ])); |
| 48 expect(result.value, completion([0, 1, 2, 0])); |
| 49 }); |
| 50 |
| 51 test("no events", () { |
| 52 var result = collectBytesCancelable(new Stream.fromIterable([])); |
| 53 expect(result.value, completion([])); |
| 54 }); |
| 55 |
| 56 test("empty events", () { |
| 57 var result = collectBytesCancelable(new Stream.fromIterable([[], []])); |
| 58 expect(result.value, completion([])); |
| 59 }); |
| 60 |
| 61 test("error event", () { |
| 62 var result = collectBytesCancelable(new Stream.fromIterable( |
| 63 new Iterable.generate(3, (n) => n == 2 ? throw "badness" : [n]))); |
| 64 expect(result.value, throwsA("badness")); |
| 65 }); |
| 66 |
| 67 test("cancelled", () async { |
| 68 var sc = new StreamController<List<int>>(); |
| 69 var result = collectBytesCancelable(sc.stream); |
| 70 // Value never completes. |
| 71 result.value.whenComplete(expectAsync0((){}, count: 0)); |
| 72 |
| 73 expect(sc.hasListener, isTrue); |
| 74 sc.add([1, 2]); |
| 75 await nextTimerTick(); |
| 76 expect(sc.hasListener, isTrue); |
| 77 sc.add([3, 4]); |
| 78 await nextTimerTick(); |
| 79 expect(sc.hasListener, isTrue); |
| 80 result.cancel(); |
| 81 expect(sc.hasListener, isFalse); // Cancelled immediately. |
| 82 var replacement = await result.valueOrCancellation(); |
| 83 expect(replacement, isNull); |
| 84 await nextTimerTick(); |
| 85 sc.close(); |
| 86 await nextTimerTick(); |
| 87 }); |
| 88 }); |
39 } | 89 } |
| 90 |
| 91 Future nextTimerTick() => new Future((){}); |
OLD | NEW |