Index: sdk/lib/io/http_impl.dart |
diff --git a/sdk/lib/io/http_impl.dart b/sdk/lib/io/http_impl.dart |
index cfdab32b30778d3197ec6b99fea220f79eed8af8..f30d76cc97e09f48defadb91ba29c82c403e5885 100644 |
--- a/sdk/lib/io/http_impl.dart |
+++ b/sdk/lib/io/http_impl.dart |
@@ -547,8 +547,10 @@ class _HttpOutboundConsumer implements StreamConsumer { |
_ensureController() { |
if (_controller != null) return; |
- _controller = new StreamController(onPauseStateChange: _onPause, |
- onSubscriptionStateChange: _onListen); |
+ _controller = new StreamController(onPause: _onPause, |
+ onResume: _onPause, |
+ onListen: _onListen, |
+ onCancel: _onListen); |
_outbound._addStream(_controller.stream) |
.then((_) { |
_done(); |