From a7666e2112ee6ec957d1972def10b83f1d4e3662 Mon Sep 17 00:00:00 2001 From: Benoit Marty Date: Mon, 22 Aug 2022 17:37:29 +0200 Subject: [PATCH] Set instead of List, to avoid duplication. --- .../session/sync/SyncResponsePostTreatmentAggregator.kt | 2 +- .../handler/SyncResponsePostTreatmentAggregatorHandler.kt | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/SyncResponsePostTreatmentAggregator.kt b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/SyncResponsePostTreatmentAggregator.kt index 14f89e8a34..2e1863a034 100644 --- a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/SyncResponsePostTreatmentAggregator.kt +++ b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/SyncResponsePostTreatmentAggregator.kt @@ -24,7 +24,7 @@ internal class SyncResponsePostTreatmentAggregator { val directChatsToCheck = mutableMapOf() // List of userIds to fetch and update at the end of incremental syncs - val userIdsToFetch = mutableListOf() + val userIdsToFetch = mutableSetOf() // Set of users to call `crossSigningService.onUsersDeviceUpdate` once per sync val userIdsWithDeviceUpdate = mutableSetOf() diff --git a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/handler/SyncResponsePostTreatmentAggregatorHandler.kt b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/handler/SyncResponsePostTreatmentAggregatorHandler.kt index fb7b7c60a0..b7806d154b 100644 --- a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/handler/SyncResponsePostTreatmentAggregatorHandler.kt +++ b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/handler/SyncResponsePostTreatmentAggregatorHandler.kt @@ -83,13 +83,13 @@ internal class SyncResponsePostTreatmentAggregatorHandler @Inject constructor( } } - private suspend fun fetchAndUpdateUsers(userIdsToFetch: List) { + private suspend fun fetchAndUpdateUsers(userIdsToFetch: Collection) { fetchUsers(userIdsToFetch) .takeIf { it.isNotEmpty() } ?.saveLocally() } - private suspend fun fetchUsers(userIdsToFetch: List) = userIdsToFetch.mapNotNull { + private suspend fun fetchUsers(userIdsToFetch: Collection) = userIdsToFetch.mapNotNull { tryOrNull { val profileJson = getProfileInfoTask.execute(GetProfileInfoTask.Params(it)) User.fromJson(it, profileJson)