| Index: tests/lib/async/catch_errors22_test.dart
|
| diff --git a/tests/lib/async/catch_errors22_test.dart b/tests/lib/async/catch_errors22_test.dart
|
| index 46debaf65eb934c1955e87ed9beeed60d73ea040..8f810e70737a9b794fad2a8d992414bc512f5fc1 100644
|
| --- a/tests/lib/async/catch_errors22_test.dart
|
| +++ b/tests/lib/async/catch_errors22_test.dart
|
| @@ -16,25 +16,33 @@ main() {
|
| // Test that streams that are never closed keep the `catchError` alive.
|
| catchErrors(() {
|
| catchErrors(() {
|
| - controller.stream.map((x) { throw x; }).listen((x) {
|
| + controller.stream.map((x) {
|
| + throw x;
|
| + }).listen((x) {
|
| // Should not happen.
|
| events.add("bad: $x");
|
| });
|
| - }).listen((x) { events.add("caught: $x"); },
|
| - onDone: () { events.add("done"); });
|
| - }).listen((x) { events.add("outer: $x"); },
|
| - onDone: () { onDoneWasCalled = true; });
|
| + }).listen((x) {
|
| + events.add("caught: $x");
|
| + }, onDone: () {
|
| + events.add("done");
|
| + });
|
| + }).listen((x) {
|
| + events.add("outer: $x");
|
| + }, onDone: () {
|
| + onDoneWasCalled = true;
|
| + });
|
|
|
| [1, 2, 3, 4].forEach(controller.add);
|
|
|
| new Timer(const Duration(milliseconds: 20), () {
|
| Expect.isFalse(onDoneWasCalled);
|
| - Expect.listEquals(["caught: 1",
|
| - "caught: 2",
|
| - "caught: 3",
|
| - "caught: 4",
|
| - ],
|
| - events);
|
| + Expect.listEquals([
|
| + "caught: 1",
|
| + "caught: 2",
|
| + "caught: 3",
|
| + "caught: 4",
|
| + ], events);
|
| asyncEnd();
|
| });
|
| }
|
|
|