Index: sdk/lib/async/stream_controller.dart |
diff --git a/sdk/lib/async/stream_controller.dart b/sdk/lib/async/stream_controller.dart |
index 24a9999b654b0c1a29700d3ea9e1b4155dd9e140..6fcc53746f8eada82fef6f84e6e12646f7e0c441 100644 |
--- a/sdk/lib/async/stream_controller.dart |
+++ b/sdk/lib/async/stream_controller.dart |
@@ -50,22 +50,6 @@ class StreamController<T> extends EventSink<T> { |
final _StreamImpl<T> stream; |
/** |
- * A controller with a broadcast [stream].. |
- * |
- * The [onPauseStateChange] function is called when the stream becomes |
- * paused or resumes after being paused. The current pause state can |
- * be read from [isPaused]. Ignored if [:null:]. |
- * |
- * The [onSubscriptionStateChange] function is called when the stream |
- * receives its first listener or loses its last. The current subscription |
- * state can be read from [hasListener]. Ignored if [:null:]. |
- */ |
- StreamController.broadcast({void onPauseStateChange(), |
- void onSubscriptionStateChange()}) |
- : stream = new _MultiControllerStream<T>(onSubscriptionStateChange, |
- onPauseStateChange); |
- |
- /** |
* A controller with a [stream] that supports only one single subscriber. |
* |
* The controller will buffer all incoming events until the subscriber is |
@@ -141,33 +125,6 @@ class StreamController<T> extends EventSink<T> { |
typedef void _NotificationHandler(); |
-class _MultiControllerStream<T> extends _MultiStreamImpl<T> { |
- _NotificationHandler _subscriptionHandler; |
- _NotificationHandler _pauseHandler; |
- |
- _MultiControllerStream(this._subscriptionHandler, this._pauseHandler); |
- |
- void _onSubscriptionStateChange() { |
- if (_subscriptionHandler != null) { |
- try { |
- _subscriptionHandler(); |
- } catch (e, s) { |
- new AsyncError(e, s).throwDelayed(); |
- } |
- } |
- } |
- |
- void _onPauseStateChange() { |
- if (_pauseHandler != null) { |
- try { |
- _pauseHandler(); |
- } catch (e, s) { |
- new AsyncError(e, s).throwDelayed(); |
- } |
- } |
- } |
-} |
- |
class _SingleControllerStream<T> extends _SingleStreamImpl<T> { |
_NotificationHandler _subscriptionHandler; |
_NotificationHandler _pauseHandler; |