Chromium Code Reviews| 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? |
| } |