| Index: sdk/lib/io/http_parser.dart
 | 
| diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart
 | 
| index 7d098d02a8e0d2e4a56eb5042e04f9fbbd3a376d..20de2386f701af0c310423e60fe5723e7eff03f0 100644
 | 
| --- a/sdk/lib/io/http_parser.dart
 | 
| +++ b/sdk/lib/io/http_parser.dart
 | 
| @@ -166,7 +166,7 @@ class _HttpDetachedIncoming extends Stream<List<int>> {
 | 
|    }
 | 
|  
 | 
|    void onSubscriptionStateChange() {
 | 
| -    if (controller.hasSubscribers) {
 | 
| +    if (controller.hasListener) {
 | 
|        resume();
 | 
|      } else {
 | 
|        subscription.cancel();
 | 
| @@ -912,7 +912,7 @@ class _HttpParser
 | 
|    }
 | 
|  
 | 
|    void _bodySubscriptionStateChange() {
 | 
| -    if (_incoming != null && !_bodyController.hasSubscribers) {
 | 
| +    if (_incoming != null && !_bodyController.hasListener) {
 | 
|        _closeIncoming();
 | 
|      } else {
 | 
|        _updateParsePauseState();
 | 
| @@ -921,13 +921,13 @@ class _HttpParser
 | 
|  
 | 
|    void _updateParsePauseState() {
 | 
|      if (_bodyController != null) {
 | 
| -      if (_bodyController.hasSubscribers && !_bodyController.isPaused) {
 | 
| +      if (_bodyController.hasListener && !_bodyController.isPaused) {
 | 
|          _continueParsing();
 | 
|        } else {
 | 
|          _pauseParsing();
 | 
|        }
 | 
|      } else {
 | 
| -      if (_controller.hasSubscribers && !_controller.isPaused) {
 | 
| +      if (_controller.hasListener && !_controller.isPaused) {
 | 
|          _continueParsing();
 | 
|        } else {
 | 
|          _pauseParsing();
 | 
| 
 |