Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(816)

Unified Diff: sdk/lib/io/http_parser.dart

Issue 12610006: Renamed StreamSink to EventSink. Renamed signalError to addError. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Changed inheritance back! Now create StreamSink instead of EventSink where we create them. Created 7 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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();
}

Powered by Google App Engine
This is Rietveld 408576698