diff --git a/server/sockets/webrtc.ts b/server/sockets/webrtc.ts
index e63e736..5e76a41 100644
--- a/server/sockets/webrtc.ts
+++ b/server/sockets/webrtc.ts
@@ -126,8 +126,10 @@ export default function (io: SocketServer, router: types.Router) {
     socket.data.consumers = new Map()
 
     socket.on('join', async ({ username, rtpCapabilities }, cb) => {
-      if (socket.data.joined)
-        throw new Error('Already joined')
+      if (socket.data.joined) {
+        consola.error('[WebRtc]', 'Already joined')
+        cb({ error: 'Already joined' })
+      }
 
       socket.data.joined = true
       socket.data.username = username