Index: tests/lib/async/stream_controller_async_test.dart |
diff --git a/tests/lib/async/stream_controller_async_test.dart b/tests/lib/async/stream_controller_async_test.dart |
index dca28e1709e88e9fa8c9792211e56315ed928391..f1cf3dbc135e2d725abf86f526b3053c57eae0f8 100644 |
--- a/tests/lib/async/stream_controller_async_test.dart |
+++ b/tests/lib/async/stream_controller_async_test.dart |
@@ -14,8 +14,8 @@ import 'event_helper.dart'; |
testController() { |
// Test fold |
test("StreamController.fold", () { |
- StreamController c = new StreamController.broadcast(); |
- Stream stream = c.stream; |
+ StreamController c = new StreamController(); |
+ Stream stream = c.stream.asBroadcastStream(); |
stream.fold(0, (a,b) => a + b) |
.then(expectAsync1((int v) { |
Expect.equals(42, v); |
@@ -26,8 +26,8 @@ testController() { |
}); |
test("StreamController.fold throws", () { |
- StreamController c = new StreamController.broadcast(); |
- Stream stream = c.stream; |
+ StreamController c = new StreamController(); |
+ Stream stream = c.stream.asBroadcastStream(); |
stream.fold(0, (a,b) { throw "Fnyf!"; }) |
.catchError(expectAsync1((e) { Expect.equals("Fnyf!", e.error); })); |
c.add(42); |