Ensure we close file handles and streams

porsager · Feb 18, 2024 · e934bbf · e934bbf
1 parent defa97c
commit e934bbf
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/request.js b/src/request.js
@@ -533,7 +533,7 @@ function stream(r, type, { handle, stat, compressor }, options) {
     compressor
       ? r.header('Transfer-Encoding', 'chunked')
       : r.header('Content-Length', size)
-    return r.end()
+    return Promise.resolve(r.end())
   }
 
   return compressor
@@ -574,6 +574,11 @@ async function streamCompressed(r, handle, compressor, highWaterMark, total, sta
     , reject
     , resume
 
+  r.onAborted(() => {
+    resume && resume()
+    compressStream.destroy()
+  })
+
   const promise = new Promise((r, e) => (resolve = r, reject = e))
 
   compressStream.on('data', x => ok = r.write(x))