Index: tests/lib/async/stream_transform_test.dart |
diff --git a/tests/lib/async/stream_transform_test.dart b/tests/lib/async/stream_transform_test.dart |
index 40c480c23bc27ef18e287389be2c2f48e6d96a3d..a543512cd08f6d2318e453a2333839fbf6225dc7 100644 |
--- a/tests/lib/async/stream_transform_test.dart |
+++ b/tests/lib/async/stream_transform_test.dart |
@@ -16,7 +16,7 @@ main() { |
test("simpleDone", () { |
StreamController c = new StreamController(sync: true); |
Stream out = c.stream.handleError((x){}).handleError((x){}); |
- out.listen((v){}, onDone: expectAsync0(() {})); |
+ out.listen((v){}, onDone: expectAsync(() {})); |
// Should not throw. |
c.close(); |
}); |
@@ -27,7 +27,7 @@ main() { |
Events input = new Events.fromIterable([1, 2, 3, 4, 5, 6, 7]); |
Events actual = new Events.capture( |
c.stream.map((x) => x * 2).where((x) => x > 5).skip(2).take(2)); |
- actual.onDone(expectAsync0(() { |
+ actual.onDone(expectAsync(() { |
Expect.listEquals(expected.events, actual.events); |
})); |
input.replay(c); |
@@ -39,7 +39,7 @@ main() { |
Events input = new Events.fromIterable([1, 2, 3, 4, 5, 6, 7]); |
Events actual = new Events.capture( |
c.stream.map((x) => x * 2).where((x) => x > 5).skip(2).take(2)); |
- actual.onDone(expectAsync0(() { |
+ actual.onDone(expectAsync(() { |
Expect.listEquals(expected.events, actual.events); |
})); |
actual.pause(); |
@@ -53,7 +53,7 @@ main() { |
.transform(new StreamTransformer.fromHandlers( |
handleData: (element, sink) { sink.add(element); }, |
handleDone: (sink) { sink.close(); })) |
- .listen(expectAsync1((e) => expect(e, equals("foo")))); |
+ .listen(expectAsync((e) => expect(e, equals("foo")))); |
controller.add("foo"); |
// Should not crash. |