Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1351)

Unified Diff: tests/lib/async/catch_errors25_test.dart

Issue 15864007: Add zone support to streams. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Rebase Created 7 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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");
}

Powered by Google App Engine
This is Rietveld 408576698