diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java index 06bf787f7..3243b8dd4 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java @@ -1019,9 +1019,9 @@ public class AccountsManager { registrationRecoveryPasswordsManager.removeForNumber(account.getNumber())) .thenCompose(ignored -> accounts.delete(account.getUuid(), additionalWriteItems)) .thenCompose(ignored -> redisDeleteAsync(account)) - .thenRun(() -> RedisOperation.unchecked(() -> + .thenRunAsync(() -> RedisOperation.unchecked(() -> account.getDevices().forEach(device -> - clientPresenceManager.disconnectPresence(account.getUuid(), device.getId())))); + clientPresenceManager.disconnectPresence(account.getUuid(), device.getId()))), clientPresenceExecutor); } private String getUsernameHashAccountMapKey(byte[] usernameHash) {