Make asBroadcastStream take two callbacks.

sdk/lib/_internal/pub/test/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 189 matching lines @@
       }), completes);
     });
   });
 
   group('with a single stream', () {
     StreamController controller;
     Stream stream;
 
     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', () {
       StreamIterator iter = new StreamIterator(stream);
       iter.moveNext().then((hasNext) {
         expect(hasNext, isTrue);
         expect(iter.current, equals(1));
         iter.moveNext().then((hasNext) {
           expect(hasNext, isTrue);
           expect(iter.current, equals(2));
@@ skipping 99 matching lines @@
   });
 
   group('with multiple streams', () {
     StreamController controller1;
     StreamController controller2;
     Stream stream1;
     Stream stream2;
 
     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",
         () {
       expect(stream1.first, throwsFormatException);
       expect(stream2.first, throwsFormatException);
       expect(errorGroup.done, throwsFormatException);
 
       controller1.addError(new FormatException());
     });
@@ skipping 35 matching lines @@
   });
 
   group('with a stream and a future', () {
     StreamController controller;
     Stream stream;
     Completer completer;
     Future future;
 
     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);
     });
 
     test("should pipe exceptions from the stream to the future", () {
       expect(stream.first, throwsFormatException);
       expect(future, throwsFormatException);
       expect(errorGroup.done, throwsFormatException);
 
       controller.addError(new FormatException());
@@ skipping 35 matching lines @@
              completion(equals(['value1', 'value2'])));
       controller..add('value1')..add('value2')..close();
 
       expect(signal.future.then((_) {
         // shouldn't cause a top-level exception
         completer.completeError(new FormatException());
       }), completes);
     });
   });
 }