Index: sdk/lib/async/stream_controller.dart |
diff --git a/sdk/lib/async/stream_controller.dart b/sdk/lib/async/stream_controller.dart |
index cf49a17c85a2f27f88fccbcfc91b113db1287201..cc4d9e15de9397d030ebc267c9d3784006d2db80 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); |
} |