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