From 6f3e6fc4a7922ba67c5866e664ae3a564d95a504 Mon Sep 17 00:00:00 2001
From: Leaf Petersen <leafp@google.com>
Date: Fri, 2 Mar 2018 11:22:57 -0800
Subject: [PATCH] Remove internal uses of deprecated .typed and format

---
 lib/src/lazy_stream.dart              | 5 ++---
 lib/src/typed_stream_transformer.dart | 5 +----
 2 files changed, 3 insertions(+), 7 deletions(-)

diff --git a/lib/src/lazy_stream.dart b/lib/src/lazy_stream.dart
index f07c387..cf65a79 100644
--- a/lib/src/lazy_stream.dart
+++ b/lib/src/lazy_stream.dart
@@ -4,7 +4,6 @@
 
 import "dart:async";
 
-import "delegate/stream.dart";
 import "stream_completer.dart";
 import "utils.dart";
 
@@ -40,10 +39,10 @@ class LazyStream<T> extends Stream<T> {
     Stream<T> stream;
     if (result is Future<Stream<T>>) {
       stream = StreamCompleter.fromFuture(result.then((stream) {
-        return DelegatingStream.typed<T>(stream);
+        return stream.cast<T>();
       }));
     } else {
-      stream = DelegatingStream.typed<T>(result as Stream);
+      stream = (result as Stream).cast<T>();
     }
 
     return stream.listen(onData,
diff --git a/lib/src/typed_stream_transformer.dart b/lib/src/typed_stream_transformer.dart
index cb63311..6a428fa 100644
--- a/lib/src/typed_stream_transformer.dart
+++ b/lib/src/typed_stream_transformer.dart
@@ -4,8 +4,6 @@
 
 import 'dart:async';
 
-import 'delegate/stream.dart';
-
 /// Creates a wrapper that coerces the type of [transformer].
 ///
 /// This soundly converts a [StreamTransformer] to a `StreamTransformer<S, T>`,
@@ -25,6 +23,5 @@ class _TypeSafeStreamTransformer<S, T> extends StreamTransformerBase<S, T> {
 
   _TypeSafeStreamTransformer(this._inner);
 
-  Stream<T> bind(Stream<S> stream) =>
-      DelegatingStream.typed(_inner.bind(stream));
+  Stream<T> bind(Stream<S> stream) => _inner.bind(stream).cast();
 }