| Index: tests/lib/async/catch_errors25_test.dart
|
| diff --git a/tests/lib/async/catch_errors4_test.dart b/tests/lib/async/catch_errors25_test.dart
|
| similarity index 63%
|
| copy from tests/lib/async/catch_errors4_test.dart
|
| copy to tests/lib/async/catch_errors25_test.dart
|
| index d14f948911d101cfd7d8fb00e6ebcffc87981909..706a1843c14050fa1453e974ff6ff0dd6a83d7b1 100644
|
| --- a/tests/lib/async/catch_errors4_test.dart
|
| +++ b/tests/lib/async/catch_errors25_test.dart
|
| @@ -11,21 +11,19 @@ main() {
|
| // time out if the callbacks are not invoked.
|
| var port = new ReceivePort();
|
| var events = [];
|
| - // Test that synchronous errors inside a `catchErrors` are caught.
|
| + StreamController controller;
|
| + // Test multiple subscribers of an asBroadcastStream inside the same
|
| + // `catchErrors`.
|
| catchErrors(() {
|
| - events.add("catch error entry");
|
| - throw "catch error";
|
| - }).listen((x) {
|
| - events.add(x);
|
| - },
|
| - onDone: () {
|
| + var stream = new Stream.fromIterable([1, 2]).asBroadcastStream();
|
| + stream.listen(events.add);
|
| + stream.listen(events.add);
|
| + }).listen((x) { events.add("outer: $x"); },
|
| + onDone: () {
|
| Expect.listEquals([
|
| - "catch error entry",
|
| - "main exit",
|
| - "catch error",
|
| + 1, 1, 2, 2,
|
| ],
|
| events);
|
| port.close();
|
| });
|
| - events.add("main exit");
|
| }
|
|
|