| Index: sdk/lib/async/broadcast_stream_controller.dart
|
| diff --git a/sdk/lib/async/broadcast_stream_controller.dart b/sdk/lib/async/broadcast_stream_controller.dart
|
| index 075386102069ffcbbd4ffb21c3e920233de4f82b..198f96cb2bb969342703f9ece4944aaffc25b5e3 100644
|
| --- a/sdk/lib/async/broadcast_stream_controller.dart
|
| +++ b/sdk/lib/async/broadcast_stream_controller.dart
|
| @@ -514,31 +514,3 @@ class _AsBroadcastStreamController<T> extends _SyncBroadcastStreamController<T>
|
| super._callOnCancel();
|
| }
|
| }
|
| -
|
| -// A subscription that never receives any events.
|
| -// It can simulate pauses, but otherwise does nothing.
|
| -class _DoneSubscription<T> implements StreamSubscription<T> {
|
| - int _pauseCount = 0;
|
| - void onData(void handleData(T data)) {}
|
| - void onError(Function handleError) {}
|
| - void onDone(void handleDone()) {}
|
| - void pause([Future resumeSignal]) {
|
| - if (resumeSignal != null) resumeSignal.then(_resume);
|
| - _pauseCount++;
|
| - }
|
| -
|
| - void resume() {
|
| - _resume(null);
|
| - }
|
| -
|
| - void _resume(_) {
|
| - if (_pauseCount > 0) _pauseCount--;
|
| - }
|
| -
|
| - Future cancel() {
|
| - return new _Future.immediate(null);
|
| - }
|
| -
|
| - bool get isPaused => _pauseCount > 0;
|
| - Future<E> asFuture<E>([E value]) => new _Future<E>();
|
| -}
|
|
|