diff options
| author | Shigeki Ohtsu <ohtsu@iij.ad.jp> | 2012-12-18 10:59:07 +0900 |
|---|---|---|
| committer | isaacs <i@izs.me> | 2012-12-26 15:20:48 -0800 |
| commit | 8bf0c15a5b21755c4c66b54f5aad16e81a416c13 (patch) | |
| tree | 63f853cbf65a1477ef86bbbee679f96a4b2cbaca /lib/http.js | |
| parent | ce30683012186f8573da7691c528ad6ab7e15407 (diff) | |
| download | android-node-v8-8bf0c15a5b21755c4c66b54f5aad16e81a416c13.tar.gz android-node-v8-8bf0c15a5b21755c4c66b54f5aad16e81a416c13.tar.bz2 android-node-v8-8bf0c15a5b21755c4c66b54f5aad16e81a416c13.zip | |
stream2: fix to emit end event on http.ClientResponse
Diffstat (limited to 'lib/http.js')
| -rw-r--r-- | lib/http.js | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/http.js b/lib/http.js index 43c61b5e43..5013f3c0a3 100644 --- a/lib/http.js +++ b/lib/http.js @@ -160,6 +160,11 @@ function parserOnMessageComplete() { stream._readableState.onread(null, null); } + if (!stream._readableState.endEmitted && !parser.incoming._pendings.length) { + // For emit end event + stream._readableState.onread(null, null); + } + if (parser.socket.readable) { // force to read the next incoming message parser.socket.resume(); |