Index: sdk/lib/async/stream_controller.dart |
diff --git a/sdk/lib/async/stream_controller.dart b/sdk/lib/async/stream_controller.dart |
index b362be894661711f5cdfcd7db305f99f8baaa28c..d29cfdca587a26b3409012ea29f16fab0775e459 100644 |
--- a/sdk/lib/async/stream_controller.dart |
+++ b/sdk/lib/async/stream_controller.dart |
@@ -42,7 +42,7 @@ class StreamController<T> extends Stream<T> implements StreamSink<T> { |
/** |
* A controller with a [stream] that supports multiple subscribers. |
*/ |
- StreamController() { |
+ StreamController.multiSubscription() { |
_stream = new _MultiControllerStream<T>(onSubscriptionStateChange, |
onPauseStateChange); |
} |
@@ -51,7 +51,7 @@ class StreamController<T> extends Stream<T> implements StreamSink<T> { |
* The controller will buffer all incoming events until the subscriber is |
* registered. |
*/ |
- StreamController.singleSubscription() { |
+ StreamController() { |
_stream = new _SingleControllerStream<T>(onSubscriptionStateChange, |
onPauseStateChange); |
} |