Index: tests/lib_strong/async/catch_errors16_test.dart |
diff --git a/tests/lib_strong/async/catch_errors16_test.dart b/tests/lib_strong/async/catch_errors16_test.dart |
index 89f18a4626cd28f866a3975041c617c0f17f7582..40a2c63f37f6a9695c1879cd2ca6c5dd8333bd5f 100644 |
--- a/tests/lib_strong/async/catch_errors16_test.dart |
+++ b/tests/lib_strong/async/catch_errors16_test.dart |
@@ -17,18 +17,21 @@ main() { |
// the nested `catchError` won't see the error. |
catchErrors(() { |
stream = stream.map((x) => x + 100); |
- }).listen((x) { events.add(x); }); |
+ }).listen((x) { |
+ events.add(x); |
+ }); |
stream |
- .transform(new StreamTransformer.fromHandlers( |
- handleError: (e, st, sink) { sink.add("error $e"); })) |
- .listen((x) { events.add("stream $x"); }, |
- onDone: () { |
- Expect.listEquals(["stream 101", |
- "stream error 2", |
- ], |
- events); |
- asyncEnd(); |
- }); |
+ .transform(new StreamTransformer.fromHandlers(handleError: (e, st, sink) { |
+ sink.add("error $e"); |
+ })).listen((x) { |
+ events.add("stream $x"); |
+ }, onDone: () { |
+ Expect.listEquals([ |
+ "stream 101", |
+ "stream error 2", |
+ ], events); |
+ asyncEnd(); |
+ }); |
controller.add(1); |
controller.addError(2); |
controller.close(); |