| 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 |