Fix sending streams on Node 10

medleyjs · May 1, 2018 · 5042497 · 5042497
1 parent b9d464f
commit 5042497
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/lib/Response.js b/lib/Response.js
@@ -261,11 +261,12 @@ function sendFinalPayload(res, payload) {
 }
 
 function sendStream(payload, resStream, res) {
-  var sourceOpen = true
+  var payloadOpen = true
+  var resOpen = true
 
   eos(payload, {readable: true, writable: false}, (err) => {
-    sourceOpen = false
-    if (!err) {
+    payloadOpen = false
+    if (!err || !resOpen) {
       return
     }
 
@@ -279,7 +280,8 @@ function sendStream(payload, resStream, res) {
   })
 
   eos(resStream, (err) => {
-    if (err && sourceOpen) {
+    resOpen = false
+    if (err && payloadOpen) {
       res.route.onStreamError(err)
       destroyStream(payload)
     }