Dispatch client presence operations after account deletion to a dedic…

…ated executor
signalapp · Dec 21, 2023 · 4d1bca2 · 4d1bca2
1 parent f33a2eb
commit 4d1bca2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 @@ private CompletableFuture<Void> delete(final Account account) {
             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) {