diff --git a/lib/requestHandler.js b/lib/requestHandler.js
index 3c93e7b..a7e86ea 100644
--- a/lib/requestHandler.js
+++ b/lib/requestHandler.js
@@ -159,7 +159,7 @@ function fetchRemoteResponse(protocol, options, reqData, config) {
 
       res.on('end', () => {
         if (resDataStream) {
-          resDataStream.emit('end'); // EOF
+          resDataStream.push(null); // indicate the stream is end
         } else {
           finishCollecting();
         }