Change singleSubscription/multiSubscription to normal/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 '../../../pkg/unittest/lib/unittest.dart';
 import '../../pub/error_group.dart';
@@ skipping 184 matching lines @@
       }), completes);
     });
   });
 
   group('with a single stream', () {
     StreamController controller;
     Stream stream;
 
     setUp(() {
       errorGroup = new ErrorGroup();
-      controller = new StreamController.multiSubscription();
+      controller = new StreamController.broadcast();
       stream = errorGroup.registerStream(controller.stream);
     });
 
     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 118 matching lines @@
   });
 
   group('with multiple streams', () {
     StreamController controller1;
     StreamController controller2;
     Stream stream1;
     Stream stream2;
 
     setUp(() {
       errorGroup = new ErrorGroup();
-      controller1 = new StreamController.multiSubscription();
-      controller2 = new StreamController.multiSubscription();
+      controller1 = new StreamController.broadcast();
+      controller2 = new StreamController.broadcast();
       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);
 
@@ skipping 33 matching lines @@
   });
 
   group('with a stream and a future', () {
     StreamController controller;
     Stream stream;
     Completer completer;
     Future future;
 
     setUp(() {
       errorGroup = new ErrorGroup();
-      controller = new StreamController.multiSubscription();
+      controller = new StreamController.broadcast();
       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);
 
@@ skipping 47 matching lines @@
 const isStateError = const _StateError();
 
 /// A matcher for functions that throw StateError.
 const Matcher throwsStateError =
     const Throws(isStateError);
 
 class _StateError extends TypeMatcher {
   const _StateError() : super("StateError");
   bool matches(item, MatchState matchState) => item is StateError;
 }