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 20638812a5e77ce5d39f5162962279fc5d1c167f..5998f3ad427c68fb4cc5404aafa1b6bcecab53a8 100644 |
--- a/tests/lib/async/stream_single_to_multi_subscriber_test.dart |
+++ b/tests/lib/async/stream_single_to_multi_subscriber_test.dart |
@@ -5,9 +5,8 @@ |
// Test the basic StreamController and StreamController.singleSubscription. |
library stream_single_test; |
-import "package:expect/expect.dart"; |
import 'dart:async'; |
-import 'package:unittest/unittest.dart'; |
+import 'package:test/test.dart'; |
import 'event_helper.dart'; |
main() { |
@@ -15,8 +14,8 @@ main() { |
StreamController c = new StreamController<int>(sync: true); |
Stream<int> multi = c.stream.asBroadcastStream(); |
// Listen twice. |
- multi.listen(expectAsync((v) => Expect.equals(42, v))); |
- multi.listen(expectAsync((v) => Expect.equals(42, v))); |
+ multi.listen(expectAsync((v) => expect(42, equals(v)))); |
+ multi.listen(expectAsync((v) => expect(42, equals(v)))); |
c.add(42); |
}); |
@@ -27,10 +26,10 @@ main() { |
Events actual1 = new Events.capture(multi); |
Events actual2 = new Events.capture(multi); |
actual1.onDone(expectAsync(() { |
- Expect.listEquals(expected.events, actual1.events); |
+ expect(expected.events, equals(actual1.events)); |
})); |
actual2.onDone(expectAsync(() { |
- Expect.listEquals(expected.events, actual2.events); |
+ expect(expected.events, equals(actual2.events)); |
})); |
expected.replay(c); |
}); |
@@ -42,10 +41,10 @@ main() { |
Events actual1 = new Events.capture(multi); |
Events actual2 = new Events.capture(multi); |
actual1.onDone(expectAsync(() { |
- Expect.listEquals(expected.events, actual1.events); |
+ expect(expected.events, equals(actual1.events)); |
})); |
actual2.onDone(expectAsync(() { |
- Expect.listEquals(expected.events, actual2.events); |
+ expect(expected.events, equals(actual2.events)); |
})); |
expected.replay(c); |
}); |