Index: sdk/lib/io/http_impl.dart |
diff --git a/sdk/lib/io/http_impl.dart b/sdk/lib/io/http_impl.dart |
index b27441b7aa87983eef6b4ae6f22743a5d15de755..7b518510cf6f569a57210eb21b0199e8dad5aa22 100644 |
--- a/sdk/lib/io/http_impl.dart |
+++ b/sdk/lib/io/http_impl.dart |
@@ -570,7 +570,7 @@ class _HttpOutboundConsumer implements StreamConsumer { |
_ensureController() { |
if (_controller != null) return; |
- _controller = new StreamController(onPause: () => _subscription.pause(), |
+ _controller = new StreamController(sync: true,onPause: () => _subscription.pause(), |
floitsch
2013/05/30 12:13:48
missing new-line.
Lasse Reichstein Nielsen
2013/05/31 05:51:59
Done.
|
onResume: () => _subscription.resume(), |
onListen: () => _subscription.resume(), |
onCancel: _cancel); |
@@ -1939,7 +1939,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? |
} |