Index: sdk/lib/io/http_parser.dart |
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart |
index bcd27e018c89ddda1ee0c65ae0be63a93b28838e..f863e4fcf9e70c42054ab822911c79641e6c5c38 100644 |
--- a/sdk/lib/io/http_parser.dart |
+++ b/sdk/lib/io/http_parser.dart |
@@ -99,13 +99,13 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
StreamController<List<int>> controller; |
final StreamSubscription subscription; |
- List<int> carryOverData; |
+ List<int> bufferedData; |
bool paused; |
Completer resumeCompleter; |
_HttpDetachedIncoming(StreamSubscription this.subscription, |
- List<int> this.carryOverData) { |
+ List<int> this.bufferedData) { |
controller = new StreamController<List<int>>( |
sync: true, |
onListen: resume, |
@@ -114,7 +114,7 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
onCancel: () => subscription.cancel()); |
if (subscription == null) { |
// Socket was already closed. |
- if (carryOverData != null) controller.add(carryOverData); |
+ if (bufferedData != null) controller.add(bufferedData); |
controller.close(); |
} else { |
pause(); |
@@ -138,9 +138,9 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
void resume() { |
paused = false; |
- if (carryOverData != null) { |
- var data = carryOverData; |
- carryOverData = null; |
+ if (bufferedData != null) { |
+ var data = bufferedData; |
+ bufferedData = null; |
controller.add(data); |
// If the consumer pauses again after the carry-over data, we'll not |
// continue our subscriber until the next resume. |