Make StreamController's unnamed constructor create a single-sub stream.

tests/lib/async/stream_controller_async_test.dart

 // Copyright (c) 2011, 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.
 
 // Test the basic StreamController and StreamController.singleSubscription.
 library stream_controller_async_test;
 
 import 'dart:async';
 import 'dart:isolate';
 import '../../../pkg/unittest/lib/unittest.dart';
 import 'event_helper.dart';
 
 testController() {
   // Test reduce
   test("StreamController.reduce", () {
-    StreamController c = new StreamController();
+    StreamController c = new StreamController.multiSubscription();
     c.reduce(0, (a,b) => a + b)
      .then(expectAsync1((int v) {
         Expect.equals(42, v);
     }));
     c.add(10);
     c.add(32);
     c.close();
   });
 
   test("StreamController.reduce throws", () {
-    StreamController c = new StreamController();
+    StreamController c = new StreamController.multiSubscription();
     c.reduce(0, (a,b) { throw "Fnyf!"; })
      .catchError(expectAsync1((e) { Expect.equals("Fnyf!", e.error); }));
     c.add(42);
   });
 
   test("StreamController.pipeInto", () {
-    StreamController c = new StreamController();
+    StreamController c = new StreamController.multiSubscription();
     var list = <int>[];
     c.pipeInto(new CollectionSink<int>(list))
      .whenComplete(expectAsync0(() {
         Expect.listEquals(<int>[1,2,9,3,9], list);
       }));
     c.add(1);
     c.add(2);
     c.add(9);
     c.add(3);
     c.add(9);
     c.close();
   });
 }
 
 testSingleController() {
   test("Single-subscription StreamController.reduce", () {
-    StreamController c = new StreamController.singleSubscription();
+    StreamController c = new StreamController();
     c.reduce(0, (a,b) => a + b)
     .then(expectAsync1((int v) { Expect.equals(42, v); }));
     c.add(10);
     c.add(32);
     c.close();
   });
 
   test("Single-subscription StreamController.reduce throws", () {
-    StreamController c = new StreamController.singleSubscription();
+    StreamController c = new StreamController();
     c.reduce(0, (a,b) { throw "Fnyf!"; })
             .catchError(expectAsync1((e) { Expect.equals("Fnyf!", e.error); }));
     c.add(42);
   });
 
   test("Single-subscription StreamController.pipeInto", () {
-    StreamController c = new StreamController.singleSubscription();
+    StreamController c = new StreamController();
     var list = <int>[];
     c.pipeInto(new CollectionSink<int>(list))
      .whenComplete(expectAsync0(() {
         Expect.listEquals(<int>[1,2,9,3,9], list);
       }));
     c.add(1);
     c.add(2);
     c.add(9);
     c.add(3);
     c.add(9);
     c.close();
   });
 
   test("Single-subscription StreamController subscription changes", () {
-    StreamController c = new StreamController.singleSubscription();
+    StreamController c = new StreamController();
     StreamSink sink = c.sink;
     Stream stream = c.stream;
     int counter = 0;
     var subscription;
     subscription = stream.listen((data) {
       counter += data;
       Expect.throws(() => stream.listen(null), (e) => e is StateError);
       subscription.cancel();
       stream.listen((data) {
         counter += data * 10;
       },
       onDone: expectAsync0(() {
         Expect.equals(1 + 20, counter);
       }));
     });
     sink.add(1);
     sink.add(2);
     sink.close();
   });
 
   test("Single-subscription StreamController events are buffered when"
        " there is no subscriber",
        () {
-    StreamController c = new StreamController.singleSubscription();
+    StreamController c = new StreamController();
     StreamSink sink = c.sink;
     Stream stream = c.stream;
     int counter = 0;
     sink.add(1);
     sink.add(2);
     sink.close();
     stream.listen(
       (data) {
         counter += data;
       },
       onDone: expectAsync0(() {
         Expect.equals(3, counter);
       }));
   });
 
   // Test subscription changes while firing.
   test("Single-subscription StreamController subscription changes while firing",
        () {
-    StreamController c = new StreamController.singleSubscription();
+    StreamController c = new StreamController();
     StreamSink sink = c.sink;
     Stream stream = c.stream;
     int counter = 0;
     var subscription = stream.listen(null);
     subscription.onData(expectAsync1((data) {
       counter += data;
       subscription.cancel();
       stream.listen((data) {
         counter += 10 * data;
       },
@@ skipping 309 matching lines @@
   testFuture("reduce", (s, act) => s.reduce(0, (a,b) => act(b)));
 }
 
 main() {
   testController();
   testSingleController();
   testExtraMethods();
   testPause();
   testRethrow();
 }