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(); |