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 414c02c2ad205d552a1f8b6ae2d60dd63c57bb4f..fc6a3cf77ded110822715519ae642efb9f6a33c0 100644 |
--- a/tests/lib/async/stream_transform_test.dart |
+++ b/tests/lib/async/stream_transform_test.dart |
@@ -14,7 +14,7 @@ main() { |
// Regression tests for http://dartbug.com/8310 and 8311 |
test("simpleDone", () { |
- StreamController c = new StreamController(); |
+ StreamController c = new StreamController(sync: true); |
Stream out = c.stream.handleError((x){}).handleError((x){}); |
out.listen((v){}, onDone: expectAsync0(() {})); |
// Should not throw. |
@@ -22,7 +22,7 @@ main() { |
}); |
test("with events", () { |
- StreamController c = new StreamController(); |
+ StreamController c = new StreamController(sync: true); |
Events expected = new Events.fromIterable([10, 12]); |
Events input = new Events.fromIterable([1, 2, 3, 4, 5, 6, 7]); |
Events actual = new Events.capture( |
@@ -34,7 +34,7 @@ main() { |
}); |
test("paused events", () { |
- StreamController c = new StreamController(); |
+ StreamController c = new StreamController(sync: true); |
Events expected = new Events.fromIterable([10, 12]); |
Events input = new Events.fromIterable([1, 2, 3, 4, 5, 6, 7]); |
Events actual = new Events.capture( |
@@ -48,7 +48,7 @@ main() { |
}); |
test("closing after done", () { |
- var controller = new StreamController(); |
+ var controller = new StreamController(sync: true); |
controller.stream.map((e) => e).transform(new StreamTransformer( |
handleData: (element, sink) { sink.add(element); }, |
handleDone: (sink) { sink.close(); }) |