diff --git a/src/node/http.ts b/src/node/http.ts
index c616c8837..c3635e073 100644
--- a/src/node/http.ts
+++ b/src/node/http.ts
@@ -738,6 +738,8 @@ export class HttpServer {
   }
 
   private onUpgrade = async (request: http.IncomingMessage, socket: net.Socket, head: Buffer): Promise<void> => {
+    socket.pause()
+
     try {
       this.heart.beat()
       socket.on("error", () => socket.destroy())