blob: e7153b2a6db6a640547abec2e5879f592cfbfba0 [file] [log] [blame]
// 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.
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)) {
void onError(Function handleError) {
void onDone(void handleDone()) {
void pause([Future resumeFuture]) {
void resume() {
Future cancel() => _source.cancel();
Future asFuture([futureValue]) => _source.asFuture(futureValue);
bool get isPaused => _source.isPaused;