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