Index: tests/lib/async/stream_from_iterable_test.dart |
diff --git a/tests/lib/async/stream_from_iterable_test.dart b/tests/lib/async/stream_from_iterable_test.dart |
index b10a636f0fea6441b557bb9f8806da646f42941f..7e58453f7db1d96ec1dcb113516159bbbdd5e486 100644 |
--- a/tests/lib/async/stream_from_iterable_test.dart |
+++ b/tests/lib/async/stream_from_iterable_test.dart |
@@ -5,8 +5,9 @@ |
// Test merging streams. |
library dart.test.stream_from_iterable; |
+import "package:expect/expect.dart"; |
import "dart:async"; |
-import 'package:test/test.dart'; |
+import 'package:unittest/unittest.dart'; |
import 'event_helper.dart'; |
class IterableTest<T> { |
@@ -19,7 +20,7 @@ class IterableTest<T> { |
Stream<T> stream = new Stream<T>.fromIterable(iterable); |
Events actual = new Events.capture(stream); |
actual.onDone(expectAsync(() { |
- expect(expected.events, equals(actual.events)); |
+ Expect.listEquals(expected.events, actual.events); |
})); |
}); |
} |
@@ -40,8 +41,8 @@ main() { |
test("iterable-toList", () { |
new Stream.fromIterable(iter).toList().then(expectAsync((actual) { |
List expected = iter.toList(); |
- expect(25, equals(expected.length)); |
- expect(expected, equals(actual)); |
+ Expect.equals(25, expected.length); |
+ Expect.listEquals(expected, actual); |
})); |
}); |
@@ -51,7 +52,7 @@ main() { |
.toList() |
.then(expectAsync((actual) { |
List expected = iter.map((i) => i * 3).toList(); |
- expect(expected, equals(actual)); |
+ Expect.listEquals(expected, actual); |
})); |
}); |
@@ -69,15 +70,15 @@ main() { |
}, onDone: expectAsync(() { |
actual.close(); |
Events expected = new Events.fromIterable(iter); |
- expect(expected.events, equals(actual.events)); |
+ Expect.listEquals(expected.events, actual.events); |
})); |
}); |
test("iterable-single-subscription", () { |
Stream stream = new Stream.fromIterable(iter); |
stream.listen((x){}); |
- expect(() { stream.listen((x){}); }, |
- throwsA(predicate((e) => e is StateError))); |
+ Expect.throws(() { stream.listen((x){}); }, |
+ (e) => e is StateError); |
}); |
test("regression-14332", () { |
@@ -98,7 +99,7 @@ main() { |
}); |
c.stream.toList().then((x) { |
- expect([1,2,3,4,5], equals(x)); |
+ Expect.listEquals([1,2,3,4,5], x); |
done(); |
}); |
}); |
@@ -116,8 +117,8 @@ main() { |
var data = [], errors = []; |
c.stream.listen(data.add, onError: errors.add, onDone: () { |
- expect([1], equals(data)); |
- expect([2], equals(errors)); |
+ Expect.listEquals([1], data); |
+ Expect.listEquals([2], errors); |
done(); |
}); |
sink.addStream(from).then((_) { |
@@ -138,8 +139,8 @@ main() { |
var data = [], errors = []; |
c.stream.listen(data.add, onError: errors.add, onDone: () { |
- expect([1, 3, 5], equals(data)); |
- expect([2, 4], equals(errors)); |
+ Expect.listEquals([1, 3, 5], data); |
+ Expect.listEquals([2, 4], errors); |
done(); |
}); |
c.addStream(from, cancelOnError: false).then((_) { |