+
+ this.liveVideosNamespace = io.of('/live-videos')
+ .on('connection', socket => {
+ socket.on('subscribe', ({ videoId }) => {
+ if (!isIdValid(videoId)) return
+
+ socket.join(videoId)
+ })
+
+ socket.on('unsubscribe', ({ videoId }) => {
+ if (!isIdValid(videoId)) return
+
+ socket.leave(videoId)
+ })
+ })