diff --git a/src/sockets.js b/src/sockets.js index 68fc53aec521637bace9db7796b87fa314aafb03..96fe00976d27d71b5352a0ac797732b0cbf31cb1 100755 --- a/src/sockets.js +++ b/src/sockets.js @@ -97,13 +97,14 @@ export default (server, config) => { name = uuid(); } // check if exists - const room = io.nsps['/'].adapter.rooms[name]; - if (room && room.length) { - safeCb(cb)('taken'); - } else { - join(name); - safeCb(cb)(null, name); - } + io.in(name).clients((err, clients) => { + if (clients && clients.length) { + safeCb(cb)('taken'); + } else { + join(name); + safeCb(cb)(null, name); + } + }); }); /*