Index: sdk/lib/io/http_impl.dart |
diff --git a/sdk/lib/io/http_impl.dart b/sdk/lib/io/http_impl.dart |
index 8cfb2a3c1cc5f7ffec5f2fe1deb2df9709a2fcc5..0a16be90a452f51db8d237f26f90b4a22a9b8cd2 100644 |
--- a/sdk/lib/io/http_impl.dart |
+++ b/sdk/lib/io/http_impl.dart |
@@ -560,7 +560,8 @@ class _HttpOutboundConsumer implements StreamConsumer { |
_ensureController() { |
if (_controller != null) return; |
- _controller = new StreamController(onPause: () => _subscription.pause(), |
+ _controller = new StreamController(sync: true, |
+ onPause: () => _subscription.pause(), |
onResume: () => _subscription.resume(), |
onListen: () => _subscription.resume(), |
onCancel: _cancel); |
@@ -1929,7 +1930,7 @@ class _HttpServer extends Stream<HttpRequest> implements HttpServer { |
// Set of currently connected clients. |
final Set<_HttpConnection> _connections = new Set<_HttpConnection>(); |
final StreamController<HttpRequest> _controller |
- = new StreamController<HttpRequest>(); |
+ = new StreamController<HttpRequest>(sync: true); |
// TODO(ajohnsen): Use close queue? |
} |