Remove StreamController.broadcast.

utils/tests/pub/error_group_test.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library error_group_test;
 
 import 'dart:async';
 
 import 'package:unittest/unittest.dart';
 
@@ skipping 185 matching lines @@
       }), completes);
     });
   });
 
   group('with a single stream', () {
     StreamController controller;
     Stream stream;
 
     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', () {
       expect(stream.elementAt(0), completion(equals(1)));
       expect(stream.elementAt(1), completion(equals(2)));
       expect(errorGroup.done, completes);
 
       controller..add(1)..add(2)..close();
     });
 
@@ skipping 117 matching lines @@
   });
 
   group('with multiple streams', () {
     StreamController controller1;
     StreamController controller2;
     Stream stream1;
     Stream stream2;
 
     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",
         () {
       expect(stream1.first, throwsFormatException);
       expect(stream2.first, throwsFormatException);
       expect(errorGroup.done, throwsFormatException);
 
       controller1.addError(new AsyncError(new FormatException()));
     });
@@ skipping 31 matching lines @@
   });
 
   group('with a stream and a future', () {
     StreamController controller;
     Stream stream;
     Completer completer;
     Future future;
 
     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);
     });
 
     test("should pipe exceptions from the stream to the future", () {
       expect(stream.first, throwsFormatException);
       expect(future, throwsFormatException);
       expect(errorGroup.done, throwsFormatException);
 
       controller.addError(new AsyncError(new FormatException()));
@@ skipping 33 matching lines @@
       expect(stream.toList(), completion(equals(['value1', 'value2'])));
       controller..add('value1')..add('value2')..close();
 
       expect(stream.toList().then((_) {
         // shouldn't cause a top-level exception
         completer.completeError(new FormatException());
       }), completes);
     });
   });
 }