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>(); |
-} |