Added toMultiSubscriber on Stream.

sdk/lib/async/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.async;
 
 // -------------------------------------------------------------------
 // Core Stream types
 // -------------------------------------------------------------------
 
 abstract class Stream<T> {
   Stream();
 
   factory Stream.fromFuture(Future<T> future) {
     var controller = new StreamController<T>();
     future.then((value) {
         controller.add(value);
         controller.close();
       },
       onError: (error) {
         controller.signalError(error);
         controller.close();
       });
     return controller.stream;
   }
 
   /**
+   * Returns a multi-subscription stream that produces the same events.

[floitsch, 2013/01/08 14:06:00]

same events as [this].

[Lasse Reichstein Nielsen, 2013/01/09 15:19:17]

Done.

+   *
+   * If this stream is single-subscription, the new multi-subscription

[floitsch, 2013/01/08 14:06:00]

As discussed: we want to be more specific on the behavior of the returned
stream.

[Lasse Reichstein Nielsen, 2013/01/09 15:19:17]

Done.

+   * stream gets its data by subscribing to this stream which must not already
+   * have a subscriber, and which can't get another subscriber at a later time.
+   *
+   * If this stream is already multi-subscriber, there is no difference between
+   * this stream and the returned stream. They may even be the same object.
+   */
+  Stream<T> toMultiSubscriber();

[floitsch, 2013/01/08 14:06:00]

asMultiSubscriptionStream()

[Lasse Reichstein Nielsen, 2013/01/09 15:19:17]

Very, very long. 
Doesn't match new StreamController.singleSubscription()

But done.

+
+  /**
    * Stream that outputs events from the [sources] in cyclic order.
    *
    * The merged streams are paused and resumed in order to ensure the proper
    * order of output events.
    */
   factory Stream.cyclic(Iterable<Stream> sources) {
     return new CyclicScheduleStream<T>(sources);
   }
 
  /**
@@ skipping 795 matching lines @@
     sink.signalError(error);
   }
 
   /**
    * Handle an incoming done event.
    */
   void handleDone(StreamSink<T> sink) {
     sink.close();
   }
 }