Index: pkg/http/lib/src/utils.dart |
diff --git a/pkg/http/lib/src/utils.dart b/pkg/http/lib/src/utils.dart |
index 4a3b84c0614ea6e71cc0d32c10dcc67570c46bef..7be3938116c20a2795895fbc2c214cc4efe2405b 100644 |
--- a/pkg/http/lib/src/utils.dart |
+++ b/pkg/http/lib/src/utils.dart |
@@ -173,7 +173,7 @@ Stream get emptyStream => streamFromIterable([]); |
/// Creates a single-subscription stream that emits the items in [iter] and then |
/// ends. |
Stream streamFromIterable(Iterable iter) { |
- var controller = new StreamController(); |
+ var controller = new StreamController(sync: true); |
iter.forEach(controller.add); |
controller.close(); |
return controller.stream; |
@@ -184,8 +184,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(); |
- var controller2 = new StreamController(); |
+ var controller1 = new StreamController(sync: true); |
+ var controller2 = new StreamController(sync: true); |
stream.listen((value) { |
controller1.add(value); |
controller2.add(value); |