From 820531120a0e45c448002044c0e75570a6e1aa2c Mon Sep 17 00:00:00 2001 From: Benoit Marty Date: Tue, 20 Apr 2021 17:33:57 +0200 Subject: [PATCH] Some formatting and cleanup --- .../features/permalink/PermalinkHandler.kt | 5 ++++- .../userdirectory/UserListViewModel.kt | 22 +++++++++++-------- 2 files changed, 17 insertions(+), 10 deletions(-) diff --git a/vector/src/main/java/im/vector/app/features/permalink/PermalinkHandler.kt b/vector/src/main/java/im/vector/app/features/permalink/PermalinkHandler.kt index a7d69c783c..ae6d630c75 100644 --- a/vector/src/main/java/im/vector/app/features/permalink/PermalinkHandler.kt +++ b/vector/src/main/java/im/vector/app/features/permalink/PermalinkHandler.kt @@ -112,7 +112,10 @@ class PermalinkHandler @Inject constructor(private val activeSessionHolder: Acti private fun PermalinkData.RoomLink.getRoomId(): Single> { val session = activeSessionHolder.getSafeActiveSession() return if (isRoomAlias && session != null) { - session.rx().getRoomIdByAlias(roomIdOrAlias, true).map { it.getOrNull()?.roomId.toOptional() }.subscribeOn(Schedulers.io()) + session.rx() + .getRoomIdByAlias(roomIdOrAlias, true) + .map { it.getOrNull()?.roomId.toOptional() } + .subscribeOn(Schedulers.io()) } else { Single.just(Optional.from(roomIdOrAlias)) } diff --git a/vector/src/main/java/im/vector/app/features/userdirectory/UserListViewModel.kt b/vector/src/main/java/im/vector/app/features/userdirectory/UserListViewModel.kt index 0e042c8bc1..a85b2cd95f 100644 --- a/vector/src/main/java/im/vector/app/features/userdirectory/UserListViewModel.kt +++ b/vector/src/main/java/im/vector/app/features/userdirectory/UserListViewModel.kt @@ -144,15 +144,19 @@ class UserListViewModel @AssistedInject constructor(@Assisted initialState: User } .onErrorReturn { Optional.empty() } - Single.zip(searchObservable, profileObservable, { searchResults, optionalProfile -> - val profile = optionalProfile.getOrNull() ?: return@zip searchResults - val searchContainsProfile = searchResults.indexOfFirst { it.userId == profile.userId } != -1 - if (searchContainsProfile) { - searchResults - } else { - listOf(profile) + searchResults - } - }) + Single.zip( + searchObservable, + profileObservable, + { searchResults, optionalProfile -> + val profile = optionalProfile.getOrNull() ?: return@zip searchResults + val searchContainsProfile = searchResults.any { it.userId == profile.userId } + if (searchContainsProfile) { + searchResults + } else { + listOf(profile) + searchResults + } + } + ) } } stream.toAsync {