From 9b88a52104de947eeb0da53b1378eff2d60cde9b Mon Sep 17 00:00:00 2001 From: Konstantinos Feretos Date: Sun, 3 Apr 2022 22:09:35 +0300 Subject: [PATCH] fix(router): socket emits (#109) --- packages/router/src/controllers/Socket/Socket.ts | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/packages/router/src/controllers/Socket/Socket.ts b/packages/router/src/controllers/Socket/Socket.ts index 01ae80e40..ca95ccb41 100644 --- a/packages/router/src/controllers/Socket/Socket.ts +++ b/packages/router/src/controllers/Socket/Socket.ts @@ -151,13 +151,7 @@ export class SocketController extends ConduitRouter { if (isNil(push.receivers) || push.receivers!.length === 0) { this.io.of(push.namespace).emit(push.event, push.data); } else { - this.io.of(push.namespace).adapter.fetchSockets({ - rooms: new Set(push.receivers) - }).then(sockets=>{ - sockets.forEach(r=>{ - r.to(push.receivers).emit(push.event, push.data) - }) - }) + this.io.of(push.namespace).to(push.receivers).emit(push.event, push.data); } } else { throw new Error('Cannot join room in this context');