| 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 8fd37e13b0c5d984135394924df1199059eda0f9..13c6f1ab93be0c4d4c00918cfc7ff9292cb9c61e 100644
|
| --- a/tests/lib/async/stream_single_to_multi_subscriber_test.dart
|
| +++ b/tests/lib/async/stream_single_to_multi_subscriber_test.dart
|
| @@ -16,8 +16,8 @@ main() {
|
| StreamController c = new StreamController<int>(sync: true);
|
| Stream<int> multi = c.stream.asBroadcastStream();
|
| // Listen twice.
|
| - multi.listen(expectAsync1((v) => Expect.equals(42, v)));
|
| - multi.listen(expectAsync1((v) => Expect.equals(42, v)));
|
| + multi.listen(expectAsync((v) => Expect.equals(42, v)));
|
| + multi.listen(expectAsync((v) => Expect.equals(42, v)));
|
| c.add(42);
|
| });
|
|
|
| @@ -27,10 +27,10 @@ main() {
|
| Events expected = new Events.fromIterable([1, 2, 3, 4, 5]);
|
| Events actual1 = new Events.capture(multi);
|
| Events actual2 = new Events.capture(multi);
|
| - actual1.onDone(expectAsync0(() {
|
| + actual1.onDone(expectAsync(() {
|
| Expect.listEquals(expected.events, actual1.events);
|
| }));
|
| - actual2.onDone(expectAsync0(() {
|
| + actual2.onDone(expectAsync(() {
|
| Expect.listEquals(expected.events, actual2.events);
|
| }));
|
| expected.replay(c);
|
| @@ -42,10 +42,10 @@ main() {
|
| Events expected = new Events.fromIterable([1, 2, 3, 4, 5]);
|
| Events actual1 = new Events.capture(multi);
|
| Events actual2 = new Events.capture(multi);
|
| - actual1.onDone(expectAsync0(() {
|
| + actual1.onDone(expectAsync(() {
|
| Expect.listEquals(expected.events, actual1.events);
|
| }));
|
| - actual2.onDone(expectAsync0(() {
|
| + actual2.onDone(expectAsync(() {
|
| Expect.listEquals(expected.events, actual2.events);
|
| }));
|
| expected.replay(c);
|
|
|