Index: sdk/lib/_internal/pub/test/error_group_test.dart |
diff --git a/sdk/lib/_internal/pub/test/error_group_test.dart b/sdk/lib/_internal/pub/test/error_group_test.dart |
index 8fbd0320c2a9335e53d259c534bd26b5f422239b..a5433bdd4d5e9aa43659c0fa3e92237e53020b77 100644 |
--- a/sdk/lib/_internal/pub/test/error_group_test.dart |
+++ b/sdk/lib/_internal/pub/test/error_group_test.dart |
@@ -207,8 +207,8 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController(sync: true); |
- stream = errorGroup.registerStream(controller.stream.asBroadcastStream()); |
+ controller = new StreamController.broadcast(sync: true); |
+ stream = errorGroup.registerStream(controller.stream); |
}); |
test('should pass through values from the stream', () { |
@@ -328,10 +328,10 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller1 = new StreamController(sync: true); |
- controller2 = new StreamController(sync: true); |
- stream1 = errorGroup.registerStream(controller1.stream.asBroadcastStream()); |
- stream2 = errorGroup.registerStream(controller2.stream.asBroadcastStream()); |
+ controller1 = new StreamController.broadcast(sync: true); |
+ controller2 = new StreamController.broadcast(sync: true); |
+ stream1 = errorGroup.registerStream(controller1.stream); |
+ stream2 = errorGroup.registerStream(controller2.stream); |
}); |
test("should pipe exceptions from one stream to the other and to .done", |
@@ -387,8 +387,8 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController(sync: true); |
- stream = errorGroup.registerStream(controller.stream.asBroadcastStream()); |
+ controller = new StreamController.broadcast(sync: true); |
+ stream = errorGroup.registerStream(controller.stream); |
completer = new Completer(); |
future = errorGroup.registerFuture(completer.future); |
}); |