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