Index: sdk/lib/io/http_parser.dart |
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart |
index 92e64c9ac83267fb62929a40024f36514546d4aa..cd088e224780c9d71da522dcab5376b3f8cffdf6 100644 |
--- a/sdk/lib/io/http_parser.dart |
+++ b/sdk/lib/io/http_parser.dart |
@@ -118,7 +118,7 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
subscription.resume(); |
subscription.onData(controller.add); |
subscription.onDone(controller.close); |
- subscription.onError(controller.signalError); |
+ subscription.onError(controller.addError); |
} |
} |
@@ -708,7 +708,7 @@ class _HttpParser |
if (_state != _State.UPGRADED && |
!(_state == _State.START && !_requestParser) && |
!(_state == _State.BODY && !_chunked && _transferLength == -1)) { |
- _bodyController.signalError( |
+ _bodyController.addError( |
new AsyncError( |
new HttpParserException( |
"Connection closed while receiving data"))); |
@@ -761,7 +761,7 @@ class _HttpParser |
} |
void _onError(e) { |
- _controller.signalError(e); |
+ _controller.addError(e); |
} |
String get version { |
@@ -929,7 +929,7 @@ class _HttpParser |
void error(error) { |
if (_socketSubscription != null) _socketSubscription.cancel(); |
_state = _State.FAILURE; |
- _controller.signalError(error); |
+ _controller.addError(error); |
_controller.close(); |
} |