Gracefully stop publication and close WS

ee/apps/ddp-streamer/src/Streamer.ts

@@ -60,7 +60,8 @@ export class Stream extends Streamer {
 			// if the connection state is not open anymore, it somehow got to a weird state,
 			// we'll emit close so it can clean up the weird state, and so we stop emitting to it
 			if (subscription.client.ws.readyState !== WebSocket.OPEN) {
-				subscription.client.ws.emit('close');
+				subscription.stop();
+				subscription.client.ws.close();
 				continue;
 			}
 
@@ -89,7 +90,8 @@ export class Stream extends Streamer {
 
 					// if we still tried to send data to a destroyed stream, we'll try again to close the connection
 					if (subscription.client.ws.readyState !== WebSocket.OPEN) {
-						subscription.client.ws.emit('close');
+						subscription.stop();
+						subscription.client.ws.close();
 					}
 				}
 				console.error('Error trying to send data to stream.', error);