diff --git a/server/sockets/webrtc.ts b/server/sockets/webrtc.ts index 1b6a96b..2eb16ad 100644 --- a/server/sockets/webrtc.ts +++ b/server/sockets/webrtc.ts @@ -259,12 +259,12 @@ export default function (io: SocketServer, router: types.Router) { cb({ id: producer.id }) - const otherSockets = await namespace.fetchSockets(socket.id) + const otherSockets = await getJoinedSockets(socket.id) for (const otherSocket of otherSockets) { createConsumer( - socket, otherSocket, + socket, producer, ) }