Index: sdk/lib/io/http_parser.dart |
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart |
index ff0fcddd8f7710acb2c93a043f44c549367a73f2..58622cf3e068a850254033cbce123ca8ac428b36 100644 |
--- a/sdk/lib/io/http_parser.dart |
+++ b/sdk/lib/io/http_parser.dart |
@@ -105,8 +105,7 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
Completer resumeCompleter; |
_HttpDetachedIncoming(StreamSubscription this.subscription, |
- List<int> this.carryOverData, |
- Completer oldResumeCompleter) { |
+ List<int> this.carryOverData) { |
controller = new StreamController<List<int>>( |
onListen: resume, |
onPause: pause, |
@@ -118,7 +117,6 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
controller.close(); |
} else { |
pause(); |
- if (oldResumeCompleter != null) oldResumeCompleter.complete(); |
subscription.resume(); |
subscription.onData(controller.add); |
subscription.onDone(controller.close); |
@@ -792,11 +790,8 @@ class _HttpParser |
void set responseToMethod(String method) { _responseToMethod = method; } |
_HttpDetachedIncoming detachIncoming() { |
- var completer = _pauseCompleter; |
- _pauseCompleter = null; |
return new _HttpDetachedIncoming(_socketSubscription, |
- readUnparsedData(), |
- completer); |
+ readUnparsedData()); |
} |
List<int> readUnparsedData() { |
@@ -993,7 +988,6 @@ class _HttpParser |
StreamSubscription _socketSubscription; |
bool _paused = true; |
bool _bodyPaused = false; |
- Completer _pauseCompleter; |
StreamController<_HttpIncoming> _controller; |
StreamController<List<int>> _bodyController; |
} |