Index: utils/tests/pub/error_group_test.dart |
diff --git a/utils/tests/pub/error_group_test.dart b/utils/tests/pub/error_group_test.dart |
index e7aa477e4d9d3eb00cacdd71bb7c98434e6a0e2d..6ffea3c53c1a310b7f34a29313a5ace3f64fac4a 100644 |
--- a/utils/tests/pub/error_group_test.dart |
+++ b/utils/tests/pub/error_group_test.dart |
@@ -203,8 +203,8 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController.broadcast(); |
- stream = errorGroup.registerStream(controller.stream); |
+ controller = new StreamController(); |
+ stream = errorGroup.registerStream(controller.stream.asBroadcastStream()); |
}); |
test('should pass through values from the stream', () { |
@@ -342,10 +342,10 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller1 = new StreamController.broadcast(); |
- controller2 = new StreamController.broadcast(); |
- stream1 = errorGroup.registerStream(controller1.stream); |
- stream2 = errorGroup.registerStream(controller2.stream); |
+ controller1 = new StreamController(); |
+ controller2 = new StreamController(); |
+ stream1 = errorGroup.registerStream(controller1.stream.asBroadcastStream()); |
+ stream2 = errorGroup.registerStream(controller2.stream.asBroadcastStream()); |
}); |
test("should pipe exceptions from one stream to the other and to .done", |
@@ -397,8 +397,8 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController.broadcast(); |
- stream = errorGroup.registerStream(controller.stream); |
+ controller = new StreamController(); |
+ stream = errorGroup.registerStream(controller.stream.asBroadcastStream()); |
completer = new Completer(); |
future = errorGroup.registerFuture(completer.future); |
}); |