Index: packages/async/test/stream_zip_zone_test.dart |
diff --git a/packages/async/test/stream_zip_zone_test.dart b/packages/async/test/stream_zip_zone_test.dart |
index 47957a9444d7bb9801cd15dabe66bd706745f172..a0773a68a8a8fc0ddf63daf35e9dda4206ea7411 100644 |
--- a/packages/async/test/stream_zip_zone_test.dart |
+++ b/packages/async/test/stream_zip_zone_test.dart |
@@ -9,22 +9,22 @@ import "package:test/test.dart"; |
// listen occurred. |
main() { |
- StreamController controller; |
- controller = new StreamController(); |
- testStream("singlesub-async", controller, controller.stream); |
- controller = new StreamController.broadcast(); |
- testStream("broadcast-async", controller, controller.stream); |
- controller = new StreamController(); |
- testStream("asbroadcast-async", controller, |
- controller.stream.asBroadcastStream()); |
+ StreamController controller; |
+ controller = new StreamController(); |
+ testStream("singlesub-async", controller, controller.stream); |
+ controller = new StreamController.broadcast(); |
+ testStream("broadcast-async", controller, controller.stream); |
+ controller = new StreamController(); |
+ testStream( |
+ "asbroadcast-async", controller, controller.stream.asBroadcastStream()); |
- controller = new StreamController(sync: true); |
- testStream("singlesub-sync", controller, controller.stream); |
- controller = new StreamController.broadcast(sync: true); |
- testStream("broadcast-sync", controller, controller.stream); |
- controller = new StreamController(sync: true); |
- testStream("asbroadcast-sync", controller, |
- controller.stream.asBroadcastStream()); |
+ controller = new StreamController(sync: true); |
+ testStream("singlesub-sync", controller, controller.stream); |
+ controller = new StreamController.broadcast(sync: true); |
+ testStream("broadcast-sync", controller, controller.stream); |
+ controller = new StreamController(sync: true); |
+ testStream( |
+ "asbroadcast-sync", controller, controller.stream.asBroadcastStream()); |
} |
void testStream(String name, StreamController controller, Stream stream) { |
@@ -33,15 +33,15 @@ void testStream(String name, StreamController controller, Stream stream) { |
runZoned(() { |
Zone newZone1 = Zone.current; |
StreamSubscription sub; |
- sub = stream.listen(expectAsync((v) { |
+ sub = stream.listen(expectAsync1((v) { |
expect(v, 42); |
expect(Zone.current, newZone1); |
outer.run(() { |
- sub.onData(expectAsync((v) { |
+ sub.onData(expectAsync1((v) { |
expect(v, 37); |
expect(Zone.current, newZone1); |
runZoned(() { |
- sub.onData(expectAsync((v) { |
+ sub.onData(expectAsync1((v) { |
expect(v, 87); |
expect(Zone.current, newZone1); |
})); |