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 ad342fe0b2c6e17fed84a3dc89061b3014f1f634..e3ef1340a640e01c346ffc082a0a1bf55cfebaec 100644 |
--- a/tests/lib/async/stream_from_iterable_test.dart |
+++ b/tests/lib/async/stream_from_iterable_test.dart |
@@ -19,7 +19,7 @@ class IterableTest<T> { |
Events expected = new Events.fromIterable(iterable); |
Stream<T> stream = new Stream<T>.fromIterable(iterable); |
Events actual = new Events.capture(stream); |
- actual.onDone(expectAsync0(() { |
+ actual.onDone(expectAsync(() { |
Expect.listEquals(expected.events, actual.events); |
})); |
}); |
@@ -39,7 +39,7 @@ main() { |
Iterable<int> iter = new Iterable.generate(25, (i) => i * 2); |
test("iterable-toList", () { |
- new Stream.fromIterable(iter).toList().then(expectAsync1((actual) { |
+ new Stream.fromIterable(iter).toList().then(expectAsync((actual) { |
List expected = iter.toList(); |
Expect.equals(25, expected.length); |
Expect.listEquals(expected, actual); |
@@ -50,7 +50,7 @@ main() { |
new Stream.fromIterable(iter) |
.map((i) => i * 3) |
.toList() |
- .then(expectAsync1((actual) { |
+ .then(expectAsync((actual) { |
List expected = iter.map((i) => i * 3).toList(); |
Expect.listEquals(expected, actual); |
})); |
@@ -67,7 +67,7 @@ main() { |
if (value == 20) { |
subscription.pause(new Future.delayed(duration, () {})); |
} |
- }, onDone: expectAsync0(() { |
+ }, onDone: expectAsync(() { |
actual.close(); |
Events expected = new Events.fromIterable(iter); |
Expect.listEquals(expected.events, actual.events); |
@@ -89,7 +89,7 @@ main() { |
var c = new StreamController(); |
var sink = c.sink; |
- var done = expectAsync0((){}, count: 2); |
+ var done = expectAsync((){}, count: 2); |
// if this goes first, test failed (hanged). Swapping addStream and toList |
// made failure go away. |
@@ -113,7 +113,7 @@ main() { |
var c = new StreamController(); |
var sink = c.sink; |
- var done = expectAsync0((){}, count: 2); |
+ var done = expectAsync((){}, count: 2); |
var data = [], errors = []; |
c.stream.listen(data.add, onError: errors.add, onDone: () { |
@@ -135,7 +135,7 @@ main() { |
var c = new StreamController(); |
- var done = expectAsync0((){}, count: 2); |
+ var done = expectAsync((){}, count: 2); |
var data = [], errors = []; |
c.stream.listen(data.add, onError: errors.add, onDone: () { |