fix(browser): prevent error stream.push() after EOF (#1932)

Co-authored-by: Daniel Lando <daniel.sorridi@gmail.com>

Author: sanduluca

src/lib/BufferedDuplex.ts

@@ -56,7 +56,7 @@ export class BufferedDuplex extends Duplex {
 		this.isSocketOpen = false
 
 		this.proxy.on('data', (chunk) => {
-			if (!this.destroyed) {
+			if (!this.destroyed && this.readable) {
 				this.push(chunk)
 			}
 		})

src/lib/connect/ws.ts

@@ -257,14 +257,15 @@ const browserStreamBuilder: StreamBuilder = (client, opts) => {
 	 * https://developer.mozilla.org/en-US/docs/Web/API/WebSocket/message_event
 	 */
 	async function onMessage(event: MessageEvent) {
+		if (!proxy || proxy.destroyed || !proxy.readable) {
+			return
+		}
 		let { data } = event
 		if (data instanceof ArrayBuffer) data = Buffer.from(data)
 		else if (data instanceof Blob)
 			data = Buffer.from(await new Response(data).arrayBuffer())
 		else data = Buffer.from(data as string, 'utf8')
-		if (proxy && !proxy.destroyed) {
-			proxy.push(data)
-		}
+		proxy.push(data)
 	}
 
 	function socketWriteBrowser(