Index: pkg/http/lib/src/utils.dart |
diff --git a/pkg/http/lib/src/utils.dart b/pkg/http/lib/src/utils.dart |
index caef51fbed363e1d62f5064d68cc4a93f1d4af0e..65c47997b1e6991c5cf460fe4ae8659432901262 100644 |
--- a/pkg/http/lib/src/utils.dart |
+++ b/pkg/http/lib/src/utils.dart |
@@ -250,16 +250,3 @@ Future forEachFuture(Iterable input, Future fn(element)) { |
} |
return nextElement(null); |
} |
- |
-// TODO(nweiz): remove this when issue 8310 is fixed. |
-/// Returns a [Stream] identical to [stream], but piped through a new |
-/// [StreamController]. This exists to work around issue 8310. |
-Stream wrapStream(Stream stream) { |
- var controller = stream.isBroadcast |
- ? new StreamController.broadcast() |
- : new StreamController(); |
- stream.listen(controller.add, |
- onError: (e) => controller.signalError(e), |
- onDone: controller.close); |
- return controller.stream; |
-} |