| Index: tests/lib/async/stream_from_iterable_test.dart
|
| diff --git a/tests/lib/async/stream_from_iterable_test.dart b/tests/lib/async/stream_from_iterable_test.dart
|
| index 7e58453f7db1d96ec1dcb113516159bbbdd5e486..7a7113a2fe6b07119228069295e2158d0fbcc811 100644
|
| --- a/tests/lib/async/stream_from_iterable_test.dart
|
| +++ b/tests/lib/async/stream_from_iterable_test.dart
|
| @@ -33,8 +33,8 @@ main() {
|
| new IterableTest<int>([1, 2, 3, 4]).run();
|
| new IterableTest<String>(["one", "two", "three", "four"]).run();
|
| new IterableTest<int>(new Iterable<int>.generate(1000, (i) => i)).run();
|
| - new IterableTest<String>(new Iterable<int>.generate(1000, (i) => i)
|
| - .map((i) => "$i")).run();
|
| + new IterableTest<String>(
|
| + new Iterable<int>.generate(1000, (i) => i).map((i) => "$i")).run();
|
|
|
| Iterable<int> iter = new Iterable.generate(25, (i) => i * 2);
|
|
|
| @@ -48,12 +48,12 @@ main() {
|
|
|
| test("iterable-mapped-toList", () {
|
| new Stream.fromIterable(iter)
|
| - .map((i) => i * 3)
|
| - .toList()
|
| - .then(expectAsync((actual) {
|
| - List expected = iter.map((i) => i * 3).toList();
|
| - Expect.listEquals(expected, actual);
|
| - }));
|
| + .map((i) => i * 3)
|
| + .toList()
|
| + .then(expectAsync((actual) {
|
| + List expected = iter.map((i) => i * 3).toList();
|
| + Expect.listEquals(expected, actual);
|
| + }));
|
| });
|
|
|
| test("iterable-paused", () {
|
| @@ -76,20 +76,21 @@ main() {
|
|
|
| test("iterable-single-subscription", () {
|
| Stream stream = new Stream.fromIterable(iter);
|
| - stream.listen((x){});
|
| - Expect.throws(() { stream.listen((x){}); },
|
| - (e) => e is StateError);
|
| + stream.listen((x) {});
|
| + Expect.throws(() {
|
| + stream.listen((x) {});
|
| + }, (e) => e is StateError);
|
| });
|
|
|
| test("regression-14332", () {
|
| // Regression test for http://dartbug.com/14332.
|
| // This should succeede.
|
| - var from = new Stream.fromIterable([1,2,3,4,5]);
|
| + var from = new Stream.fromIterable([1, 2, 3, 4, 5]);
|
|
|
| var c = new StreamController();
|
| var sink = c.sink;
|
|
|
| - var done = expectAsync((){}, count: 2);
|
| + var done = expectAsync(() {}, count: 2);
|
|
|
| // if this goes first, test failed (hanged). Swapping addStream and toList
|
| // made failure go away.
|
| @@ -99,13 +100,13 @@ main() {
|
| });
|
|
|
| c.stream.toList().then((x) {
|
| - Expect.listEquals([1,2,3,4,5], x);
|
| + Expect.listEquals([1, 2, 3, 4, 5], x);
|
| done();
|
| });
|
| });
|
|
|
| test("regression-14334-a", () {
|
| - var from = new Stream.fromIterable([1,2,3,4,5]);
|
| + var from = new Stream.fromIterable([1, 2, 3, 4, 5]);
|
|
|
| // odd numbers as data events, even numbers as error events
|
| from = from.map((x) => x.isOdd ? x : throw x);
|
| @@ -113,7 +114,7 @@ main() {
|
| var c = new StreamController();
|
| var sink = c.sink;
|
|
|
| - var done = expectAsync((){}, count: 2);
|
| + var done = expectAsync(() {}, count: 2);
|
|
|
| var data = [], errors = [];
|
| c.stream.listen(data.add, onError: errors.add, onDone: () {
|
| @@ -128,14 +129,14 @@ main() {
|
| });
|
|
|
| test("regression-14334-b", () {
|
| - var from = new Stream.fromIterable([1,2,3,4,5]);
|
| + var from = new Stream.fromIterable([1, 2, 3, 4, 5]);
|
|
|
| // odd numbers as data events, even numbers as error events
|
| from = from.map((x) => x.isOdd ? x : throw x);
|
|
|
| var c = new StreamController();
|
|
|
| - var done = expectAsync((){}, count: 2);
|
| + var done = expectAsync(() {}, count: 2);
|
|
|
| var data = [], errors = [];
|
| c.stream.listen(data.add, onError: errors.add, onDone: () {
|
|
|