Index: pkg/http/lib/src/utils.dart |
diff --git a/pkg/http/lib/src/utils.dart b/pkg/http/lib/src/utils.dart |
index bca314d95cf1828fe0f51b6b7b612b8d379d469c..87a78a0aa0e3158c87dbf78b1497f7b8aa210b95 100644 |
--- a/pkg/http/lib/src/utils.dart |
+++ b/pkg/http/lib/src/utils.dart |
@@ -155,7 +155,7 @@ Stream onDone(Stream stream, void onDone()) { |
ByteStream wrapInputStream(InputStream stream) { |
if (stream.closed) return emptyStream; |
- var controller = new StreamController.singleSubscription(); |
+ var controller = new StreamController(); |
stream.onClosed = controller.close; |
stream.onData = () => controller.add(stream.read()); |
stream.onError = (e) => controller.signalError(new AsyncError(e)); |
@@ -242,7 +242,7 @@ Stream get emptyStream => streamFromIterable([]); |
/// Creates a single-subscription stream that emits the items in [iter] and then |
/// ends. |
Stream streamFromIterable(Iterable iter) { |
- var stream = new StreamController.singleSubscription(); |
+ var stream = new StreamController(); |
iter.forEach(stream.add); |
stream.close(); |
return stream.stream; |
@@ -253,8 +253,8 @@ Stream streamFromIterable(Iterable iter) { |
/// errors from [stream]. This is useful if [stream] is single-subscription but |
/// multiple subscribers are necessary. |
Pair<Stream, Stream> tee(Stream stream) { |
- var controller1 = new StreamController.singleSubscription(); |
- var controller2 = new StreamController.singleSubscription(); |
+ var controller1 = new StreamController(); |
+ var controller2 = new StreamController(); |
stream.listen((value) { |
controller1.add(value); |
controller2.add(value); |