Index: lib/src/typed/stream.dart |
diff --git a/lib/src/typed/stream.dart b/lib/src/typed/stream.dart |
index 5b1f2ffbb1f775b22d00b184f28335e1966d71ce..a46711587ccf79333eaab3ba972f4b540a53c44a 100644 |
--- a/lib/src/typed/stream.dart |
+++ b/lib/src/typed/stream.dart |
@@ -10,7 +10,7 @@ import '../utils.dart'; |
import 'stream_subscription.dart'; |
import '../delegate/event_sink.dart'; |
-class TypeSafeStream<T> implements Stream<T> { |
+class TypeSafeStream<T> extends Stream<T> { |
floitsch
2017/05/16 09:01:18
should we add `groupBy` as an optimization?
|
final Stream _stream; |
Future<T> get first async => (await _stream.first) as T; |