OLD | NEW |
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 // part of dart.async; | 5 part of dart.async; |
6 | 6 |
7 // ------------------------------------------------------------------- | 7 // ------------------------------------------------------------------- |
8 // Default implementation of a stream with a controller for adding | 8 // Default implementation of a stream with a controller for adding |
9 // events to the stream. | 9 // events to the stream. |
10 // ------------------------------------------------------------------- | 10 // ------------------------------------------------------------------- |
11 | 11 |
12 /** | 12 /** |
13 * A controller and the stream it controls. | 13 * A controller and the stream it controls. |
14 * | 14 * |
15 * This controller allows sending data, error and done events on | 15 * This controller allows sending data, error and done events on |
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
147 _SingleControllerStream(this._subscriptionHandler, this._pauseHandler); | 147 _SingleControllerStream(this._subscriptionHandler, this._pauseHandler); |
148 | 148 |
149 void _onSubscriptionStateChange() { | 149 void _onSubscriptionStateChange() { |
150 _subscriptionHandler(); | 150 _subscriptionHandler(); |
151 } | 151 } |
152 | 152 |
153 void _onPauseStateChange() { | 153 void _onPauseStateChange() { |
154 _pauseHandler(); | 154 _pauseHandler(); |
155 } | 155 } |
156 } | 156 } |
OLD | NEW |