Index: lib/src/delegating_stream_subscription.dart |
diff --git a/lib/src/delegating_stream_subscription.dart b/lib/src/delegating_stream_subscription.dart |
deleted file mode 100644 |
index 87629e5a389e9de08af31833573a21121967afa5..0000000000000000000000000000000000000000 |
--- a/lib/src/delegating_stream_subscription.dart |
+++ /dev/null |
@@ -1,44 +0,0 @@ |
-// Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
-// for details. All rights reserved. Use of this source code is governed by a |
-// BSD-style license that can be found in the LICENSE file. |
- |
-library async.delegating_stream_subscription; |
- |
-import 'dart:async'; |
- |
-/// Simple delegating wrapper around a [StreamSubscription]. |
-/// |
-/// Subclasses can override individual methods. |
-class DelegatingStreamSubscription<T> implements StreamSubscription<T> { |
- final StreamSubscription _source; |
- |
- /// Create delegating subscription forwarding calls to [sourceSubscription]. |
- DelegatingStreamSubscription(StreamSubscription sourceSubscription) |
- : _source = sourceSubscription; |
- |
- void onData(void handleData(T data)) { |
- _source.onData(handleData); |
- } |
- |
- void onError(Function handleError) { |
- _source.onError(handleError); |
- } |
- |
- void onDone(void handleDone()) { |
- _source.onDone(handleDone); |
- } |
- |
- void pause([Future resumeFuture]) { |
- _source.pause(resumeFuture); |
- } |
- |
- void resume() { |
- _source.resume(); |
- } |
- |
- Future cancel() => _source.cancel(); |
- |
- Future asFuture([futureValue]) => _source.asFuture(futureValue); |
- |
- bool get isPaused => _source.isPaused; |
-} |