diff --git a/modules/socket/src/main/RemoteSocket.scala b/modules/socket/src/main/RemoteSocket.scala index c1d52de63a85..6240129fa671 100644 --- a/modules/socket/src/main/RemoteSocket.scala +++ b/modules/socket/src/main/RemoteSocket.scala @@ -35,7 +35,9 @@ final class RemoteSocket( case In.ConnectUser(userId) => bus.publish(lila.hub.actorApi.socket.remote.ConnectUser(userId), 'userActive) connectedUserIds += userId - case In.DisconnectUsers(userIds) => connectedUserIds --= userIds + case In.DisconnectUsers(userIds) => userIds foreach { userId => + connectedUserIds -= userId + } case In.Watch(gameId) => watchedGameIds += gameId case In.Unwatch(gameId) => watchedGameIds -= gameId case In.NotifiedBatch(userIds) => notificationActor ! lila.hub.actorApi.notify.NotifiedBatch(userIds)