Remove StreamController.broadcast.

utils/tests/pub/error_group_test.dart

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);
     });