Index: sdk/lib/io/http_parser.dart |
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart |
index 5dc129be6f8948b4b7f523ee34a6600cf1b82f05..dd55494c7010d4af1b56b99533e8d90df0c5b4db 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(); |