Change singleSubscription/multiSubscription to normal/broadcast.

sdk/lib/isolate/isolate_stream.dart

 // Copyright (c) 2012, 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.
 
 part of dart.isolate;
 
 /**
  * The initial [IsolateStream] available by default for this isolate. This
  * [IsolateStream] is created automatically and it is commonly used to establish
  * the first communication between isolates (see [streamSpawnFunction] and
@@ skipping 34 matching lines @@
 
 /**
  * [IsolateStream]s, together with [IsolateSink]s, are the only means of
  * communication between isolates. Each IsolateStream has a corresponding
  * [IsolateSink]. Any message written into that sink will be delivered to
  * the stream and then dispatched to the stream's subscribers.
  */
 class IsolateStream extends Stream<dynamic> {
   bool _isClosed = false;
   final ReceivePort _port;
-  StreamController _controller = new StreamController.multiSubscription();
+  StreamController _controller = new StreamController.broadcast();
 
   IsolateStream._fromOriginalReceivePort(this._port) {
     _port.receive((message, replyTo) {
       assert(replyTo == null);
       _add(message);
     });
   }
 
   IsolateStream._fromOriginalReceivePortOneShot(this._port) {
     _port.receive((message, replyTo) {
@@ skipping 22 matching lines @@
       _isClosed = true;
       _port.close();
       _controller.close();
     }
   }
 
   StreamSubscription listen(void onData(event),
                             { void onError(AsyncError error),
                               void onDone(),
                               bool unsubscribeOnError}) {
-      return _controller.listen(onData,
-                                onError: onError,
-                                onDone: onDone,
-                                unsubscribeOnError: unsubscribeOnError);
+      return _controller.stream.listen(onData,
+                                       onError: onError,
+                                       onDone: onDone,
+                                       unsubscribeOnError: unsubscribeOnError);
   }
 
   dynamic _unmangleMessage(var message) {
     _IsolateDecoder decoder = new _IsolateDecoder(
         _ISOLATE_STREAM_TOKEN,
         (data) {
           if (data is! List) return data;
           if (data.length == 2 && data[0] == "Sink" && data[1] is SendPort) {
             return new IsolateSink._fromPort(data[1]);
           }
@@ skipping 94 matching lines @@
  * Creates and spawns an isolate whose code is available at [uri].  Like with
  * [streamSpawnFunction], the child isolate will have a default [IsolateStream],
  * and a this function returns an [IsolateSink] feeding into it.
  *
  * See comments at the top of this library for more details.
  */
 IsolateSink streamSpawnUri(String uri) {
   SendPort sendPort = spawnUri(uri);
   return new IsolateSink._fromPort(sendPort);
 }