Immediately pause web socket

code-asher · code-asher · commit 07e7c38ea2ba · 2020-10-30T16:16:46.000-05:00
This will buffer any data sent to it until something is ready to listen
on it.
diff --git 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())

Original file line number	Diff line number	Diff line change
`@@ -738,6 +738,8 @@ export class HttpServer {`
`738`	`738`	`}`
`739`	`739`
`740`	`740`	`private onUpgrade = async (request: http.IncomingMessage, socket: net.Socket, head: Buffer): Promise<void> => {`
	`741`	`+ socket.pause()`
	`742`	`+`
`741`	`743`	`try {`
`742`	`744`	`this.heart.beat()`
`743`	`745`	`socket.on("error", () => socket.destroy())`