| Index: packages/async/lib/src/typed/stream_subscription.dart
|
| diff --git a/packages/async/lib/src/typed/stream_subscription.dart b/packages/async/lib/src/typed/stream_subscription.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..0fab0390a48d0d19e89ab4b65443aa2f9597c5cc
|
| --- /dev/null
|
| +++ b/packages/async/lib/src/typed/stream_subscription.dart
|
| @@ -0,0 +1,37 @@
|
| +// Copyright (c) 2016, 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';
|
| +
|
| +class TypeSafeStreamSubscription<T> implements StreamSubscription<T> {
|
| + final StreamSubscription _subscription;
|
| +
|
| + bool get isPaused => _subscription.isPaused;
|
| +
|
| + TypeSafeStreamSubscription(this._subscription);
|
| +
|
| + void onData(void handleData(T data)) {
|
| + _subscription.onData((data) => handleData(data as T));
|
| + }
|
| +
|
| + void onError(Function handleError) {
|
| + _subscription.onError(handleError);
|
| + }
|
| +
|
| + void onDone(void handleDone()) {
|
| + _subscription.onDone(handleDone);
|
| + }
|
| +
|
| + void pause([Future resumeFuture]) {
|
| + _subscription.pause(resumeFuture);
|
| + }
|
| +
|
| + void resume() {
|
| + _subscription.resume();
|
| + }
|
| +
|
| + Future cancel() => _subscription.cancel();
|
| +
|
| + Future<E> asFuture<E>([E futureValue]) => _subscription.asFuture(futureValue);
|
| +}
|
|
|