test(sio): bump uWebSockets.js to version 20.48.0

socketio · Sep 19, 2024 · c79cd0e · c79cd0e
1 parent 19c48a4
commit c79cd0e
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 20 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -68,7 +68,7 @@
     "ts-node": "^10.9.2",
     "tsd": "^0.31.1",
     "typescript": "^5.5.3",
-    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.30.0",
+    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.48.0",
     "wdio-geckodriver-service": "^5.0.2"
   }
 }
diff --git a/packages/socket.io/lib/uws.ts b/packages/socket.io/lib/uws.ts
@@ -135,25 +135,27 @@ export function serveFile(res /* : HttpResponse */, filepath: string) {
   const onDataChunk = (chunk: Buffer) => {
     const arrayBufferChunk = toArrayBuffer(chunk);
 
-    const lastOffset = res.getWriteOffset();
-    const [ok, done] = res.tryEnd(arrayBufferChunk, size);
+    res.cork(() => {
+      const lastOffset = res.getWriteOffset();
+      const [ok, done] = res.tryEnd(arrayBufferChunk, size);
 
-    if (!done && !ok) {
-      readStream.pause();
+      if (!done && !ok) {
+        readStream.pause();
 
-      res.onWritable((offset) => {
-        const [ok, done] = res.tryEnd(
-          arrayBufferChunk.slice(offset - lastOffset),
-          size,
-        );
+        res.onWritable((offset) => {
+          const [ok, done] = res.tryEnd(
+            arrayBufferChunk.slice(offset - lastOffset),
+            size,
+          );
 
-        if (!done && ok) {
-          readStream.resume();
-        }
+          if (!done && ok) {
+            readStream.resume();
+          }
 
-        return ok;
-      });
-    }
+          return ok;
+        });
+      }
+    });
   };
 
   res.onAborted(destroyReadStream);