OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 // Test merging streams. | 5 // Test merging streams. |
6 library dart.test.stream_from_iterable; | 6 library dart.test.stream_from_iterable; |
7 | 7 |
8 import "dart:async"; | 8 import "dart:async"; |
9 import '../../../pkg/unittest/lib/unittest.dart'; | 9 import '../../../pkg/unittest/lib/unittest.dart'; |
10 import 'event_helper.dart'; | 10 import 'event_helper.dart'; |
(...skipping 15 matching lines...) Expand all Loading... |
26 } | 26 } |
27 | 27 |
28 main() { | 28 main() { |
29 new IterableTest([]).run(); | 29 new IterableTest([]).run(); |
30 new IterableTest([1]).run(); | 30 new IterableTest([1]).run(); |
31 new IterableTest([1, "two", true, null]).run(); | 31 new IterableTest([1, "two", true, null]).run(); |
32 new IterableTest<int>([1, 2, 3, 4]).run(); | 32 new IterableTest<int>([1, 2, 3, 4]).run(); |
33 new IterableTest<String>(["one", "two", "three", "four"]).run(); | 33 new IterableTest<String>(["one", "two", "three", "four"]).run(); |
34 new IterableTest<int>(new Iterable<int>.generate(1000, (i) => i)).run(); | 34 new IterableTest<int>(new Iterable<int>.generate(1000, (i) => i)).run(); |
35 new IterableTest<String>(new Iterable<int>.generate(1000, (i) => i) | 35 new IterableTest<String>(new Iterable<int>.generate(1000, (i) => i) |
36 .mappedBy((i) => "$i")).run(); | 36 .map((i) => "$i")).run(); |
37 | 37 |
38 Iterable<int> iter = new Iterable.generate(25, (i) => i * 2); | 38 Iterable<int> iter = new Iterable.generate(25, (i) => i * 2); |
39 | 39 |
40 test("iterable-toList", () { | 40 test("iterable-toList", () { |
41 new Stream.fromIterable(iter).toList().then(expectAsync1((actual) { | 41 new Stream.fromIterable(iter).toList().then(expectAsync1((actual) { |
42 List expected = iter.toList(); | 42 List expected = iter.toList(); |
43 Expect.equals(25, expected.length); | 43 Expect.equals(25, expected.length); |
44 Expect.listEquals(expected, actual); | 44 Expect.listEquals(expected, actual); |
45 })); | 45 })); |
46 }); | 46 }); |
47 | 47 |
48 test("iterable-mapped-toList", () { | 48 test("iterable-mapped-toList", () { |
49 new Stream.fromIterable(iter) | 49 new Stream.fromIterable(iter) |
50 .mappedBy((i) => i * 3) | 50 .map((i) => i * 3) |
51 .toList() | 51 .toList() |
52 .then(expectAsync1((actual) { | 52 .then(expectAsync1((actual) { |
53 List expected = iter.mappedBy((i) => i * 3).toList(); | 53 List expected = iter.map((i) => i * 3).toList(); |
54 Expect.listEquals(expected, actual); | 54 Expect.listEquals(expected, actual); |
55 })); | 55 })); |
56 }); | 56 }); |
57 | 57 |
58 test("iterable-paused", () { | 58 test("iterable-paused", () { |
59 Stream stream = new Stream.fromIterable(iter); | 59 Stream stream = new Stream.fromIterable(iter); |
60 Events actual = new Events(); | 60 Events actual = new Events(); |
61 StreamSubscription subscription; | 61 StreamSubscription subscription; |
62 subscription = stream.listen((int value) { | 62 subscription = stream.listen((int value) { |
63 actual.add(value); | 63 actual.add(value); |
64 // Do a 10 ms pause during the playback of the iterable. | 64 // Do a 10 ms pause during the playback of the iterable. |
65 if (value == 20) { subscription.pause(new Future.delayed(10, () {})); } | 65 if (value == 20) { subscription.pause(new Future.delayed(10, () {})); } |
66 }, onDone: expectAsync0(() { | 66 }, onDone: expectAsync0(() { |
67 actual.close(); | 67 actual.close(); |
68 Events expected = new Events.fromIterable(iter); | 68 Events expected = new Events.fromIterable(iter); |
69 Expect.listEquals(expected.events, actual.events); | 69 Expect.listEquals(expected.events, actual.events); |
70 })); | 70 })); |
71 }); | 71 }); |
72 } | 72 } |
OLD | NEW |