Index: tests/lib/async/stream_single_to_multi_subscriber_test.dart |
diff --git a/tests/lib/async/stream_single_to_multi_subscriber_test.dart b/tests/lib/async/stream_single_to_multi_subscriber_test.dart |
index 3feb0497f2e0221d7e9d29f64faa0900682b5315..17a98898a45d3b86be5287c0c806a90091d2aae9 100644 |
--- a/tests/lib/async/stream_single_to_multi_subscriber_test.dart |
+++ b/tests/lib/async/stream_single_to_multi_subscriber_test.dart |
@@ -13,7 +13,7 @@ import 'event_helper.dart'; |
main() { |
test("tomulti 1", () { |
StreamController c = new StreamController<int>(); |
- Stream<int> multi = c.stream.asMultiSubscriberStream(); |
+ Stream<int> multi = c.stream.asBroadcastStream(); |
// Listen twice. |
multi.listen(expectAsync1((v) => Expect.equals(42, v))); |
multi.listen(expectAsync1((v) => Expect.equals(42, v))); |
@@ -22,7 +22,7 @@ main() { |
test("tomulti 2", () { |
StreamController c = new StreamController<int>(); |
- Stream<int> multi = c.stream.asMultiSubscriberStream(); |
+ Stream<int> multi = c.stream.asBroadcastStream(); |
Events expected = new Events.fromIterable([1, 2, 3, 4, 5]); |
Events actual1 = new Events.capture(multi); |
Events actual2 = new Events.capture(multi); |
@@ -37,7 +37,7 @@ main() { |
test("tomulti no-op", () { |
StreamController c = new StreamController<int>.multiSubscription(); |
- Stream<int> multi = c.stream.asMultiSubscriberStream(); |
+ Stream<int> multi = c.stream.asBroadcastStream(); |
Events expected = new Events.fromIterable([1, 2, 3, 4, 5]); |
Events actual1 = new Events.capture(multi); |
Events actual2 = new Events.capture(multi); |