chore: Cork serving static files (#11037)

Author: Dschoordsch

packages/server/pipeStreamOverResponse.ts

@@ -17,25 +17,27 @@ const pipeStreamOverResponse = (
         return
       }
       const ab = chunk.buffer.slice(chunk.byteOffset, chunk.byteOffset + chunk.byteLength)
-      const lastOffset = res.getWriteOffset()
-      const [ok, done] = res.tryEnd(ab as ArrayBuffer, totalSize)
-      if (done) readStream.destroy()
-      if (ok) return
-      // backpressure found!
-      readStream.pause()
-      // save the current chunk & its offset
-      res.ab = ab
-      res.abOffset = lastOffset
+      res.cork(() => {
+        const lastOffset = res.getWriteOffset()
+        const [ok, done] = res.tryEnd(ab as ArrayBuffer, totalSize)
+        if (done) readStream.destroy()
+        if (ok) return
+        // backpressure found!
+        readStream.pause()
+        // save the current chunk & its offset
+        res.ab = ab
+        res.abOffset = lastOffset
 
-      // set up a drainage
-      res.onWritable((offset) => {
-        const [ok, done] = res.tryEnd(res.ab.slice(offset - res.abOffset), totalSize)
-        if (done) {
-          readStream.destroy()
-        } else if (ok) {
-          readStream.resume()
-        }
-        return ok
+        // set up a drainage
+        res.onWritable((offset) => {
+          const [ok, done] = res.tryEnd(res.ab.slice(offset - res.abOffset), totalSize)
+          if (done) {
+            readStream.destroy()
+          } else if (ok) {
+            readStream.resume()
+          }
+          return ok
+        })
       })
     })
 

packages/server/selfHostedHandler.ts

@@ -28,7 +28,7 @@ const selfHostedHandler = async (res: HttpResponse, req: HttpRequest) => {
   const ext = path.extname(url).slice(1)
   const contentType = mime.types[ext] ?? 'application/octet-stream'
 
-  res.writeHeader('content-type', contentType)
+  res.cork(() => res.writeHeader('content-type', contentType))
   const readStream = fs.createReadStream(url)
   pipeStreamOverResponse(res, readStream, size)
 }