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..2b814b7c770a603efa96544b11d759ec3bfb0b7f 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); |
@@ -36,8 +36,8 @@ main() { |
}); |
test("tomulti no-op", () { |
- StreamController c = new StreamController<int>.multiSubscription(); |
- Stream<int> multi = c.stream.asMultiSubscriberStream(); |
+ StreamController c = new StreamController<int>.broadcast(); |
+ 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); |