Merge pull request mqttjs#1239 from ogis-yamazaki/fix_close_websocket_stream

Yoseph Maguire · web-flow · commit 59d257ac7b75 · 2021-06-15T12:28:50.000-07:00
fix mqttjs#1235
diff --git a/lib/connect/ws.js b/lib/connect/ws.js
@@ -117,6 +117,7 @@ function streamBuilder (client, opts) {
   let socket = createWebSocket(client, url, options)
   let webSocketStream = WS.createWebSocketStream(socket, options.wsOptions)
   webSocketStream.url = url
+  socket.on('close', () => { webSocketStream.destroy() })
   return webSocketStream
 }
 

Original file line number	Diff line number	Diff line change
`@@ -117,6 +117,7 @@ function streamBuilder (client, opts) {`
`117`	`117`	`let socket = createWebSocket(client, url, options)`
`118`	`118`	`let webSocketStream = WS.createWebSocketStream(socket, options.wsOptions)`
`119`	`119`	`webSocketStream.url = url`
	`120`	`+ socket.on('close', () => { webSocketStream.destroy() })`
`120`	`121`	`return webSocketStream`
`121`	`122`	`}`
`122`	`123`