| Index: tests/lib/async/catch_errors16_test.dart
|
| diff --git a/tests/lib/async/catch_errors16_test.dart b/tests/lib/async/catch_errors16_test.dart
|
| index 89f18a4626cd28f866a3975041c617c0f17f7582..40a2c63f37f6a9695c1879cd2ca6c5dd8333bd5f 100644
|
| --- a/tests/lib/async/catch_errors16_test.dart
|
| +++ b/tests/lib/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();
|
|
|