Fixed NullPointerException
This commit is contained in:
parent
d362cc31c6
commit
1076dc5521
@ -116,7 +116,11 @@ public class UserRepositoryImpl implements UserRepository {
|
|||||||
public void onRemoveRoom(Room room) {
|
public void onRemoveRoom(Room room) {
|
||||||
lock.writeLock().lock();
|
lock.writeLock().lock();
|
||||||
try {
|
try {
|
||||||
roomUsers.remove(new NodeRoomPath(room.getNodeIdentifier(), room.getIdentifier())).forEach(user -> {
|
var users = roomUsers.remove(new NodeRoomPath(room.getNodeIdentifier(), room.getIdentifier()));
|
||||||
|
|
||||||
|
if (users == null) return;
|
||||||
|
|
||||||
|
users.forEach(user -> {
|
||||||
var set = usersMap.getOrDefault(user, new HashSet<>());
|
var set = usersMap.getOrDefault(user, new HashSet<>());
|
||||||
set.remove(room);
|
set.remove(room);
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user