This commit is contained in:
@@ -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,
|
||||
)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user