From 75131fdf44f329c0ed64f61713274ae9aa718b3e Mon Sep 17 00:00:00 2001 From: Valere Date: Wed, 5 Feb 2020 15:38:58 +0100 Subject: [PATCH] Post merge fix --- .../src/main/java/im/vector/matrix/rx/LiveDataObservable.kt | 2 +- .../features/roommemberprofile/RoomMemberProfileViewModel.kt | 2 +- .../features/roomprofile/members/RoomMemberListViewModel.kt | 4 +++- 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/LiveDataObservable.kt b/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/LiveDataObservable.kt index 302e775056..60ec3c8c7d 100644 --- a/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/LiveDataObservable.kt +++ b/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/LiveDataObservable.kt @@ -58,7 +58,7 @@ private class LiveDataObservable( } } -internal fun LiveData.asObservable(): Observable { +fun LiveData.asObservable(): Observable { return LiveDataObservable(this).observeOn(Schedulers.computation()) } diff --git a/vector/src/main/java/im/vector/riotx/features/roommemberprofile/RoomMemberProfileViewModel.kt b/vector/src/main/java/im/vector/riotx/features/roommemberprofile/RoomMemberProfileViewModel.kt index e44693e4d4..2af7a6ec35 100644 --- a/vector/src/main/java/im/vector/riotx/features/roommemberprofile/RoomMemberProfileViewModel.kt +++ b/vector/src/main/java/im/vector/riotx/features/roommemberprofile/RoomMemberProfileViewModel.kt @@ -194,7 +194,7 @@ class RoomMemberProfileViewModel @AssistedInject constructor(@Assisted private v private fun observeRoomSummaryAndPowerLevels(room: Room) { val roomSummaryLive = room.rx().liveRoomSummary().unwrap() - val powerLevelsContentLive = room.rx().liveStateEvent(EventType.STATE_ROOM_POWER_LEVELS) + val powerLevelsContentLive = room.rx().liveStateEvent(EventType.STATE_ROOM_POWER_LEVELS, "") .mapOptional { it.content.toModel() } .unwrap() diff --git a/vector/src/main/java/im/vector/riotx/features/roomprofile/members/RoomMemberListViewModel.kt b/vector/src/main/java/im/vector/riotx/features/roomprofile/members/RoomMemberListViewModel.kt index bf701c2be0..72b4af4474 100644 --- a/vector/src/main/java/im/vector/riotx/features/roomprofile/members/RoomMemberListViewModel.kt +++ b/vector/src/main/java/im/vector/riotx/features/roomprofile/members/RoomMemberListViewModel.kt @@ -42,6 +42,7 @@ import im.vector.riotx.core.platform.VectorViewModel import io.reactivex.Observable import io.reactivex.android.schedulers.AndroidSchedulers import io.reactivex.functions.BiFunction +import timber.log.Timber class RoomMemberListViewModel @AssistedInject constructor(@Assisted initialState: RoomMemberListViewState, private val roomMemberSummaryComparator: RoomMemberSummaryComparator, @@ -79,7 +80,7 @@ class RoomMemberListViewModel @AssistedInject constructor(@Assisted initialState .combineLatest, PowerLevelsContent, RoomMemberSummaries>( room.rx().liveRoomMembers(roomMemberQueryParams), room.rx() - .liveStateEvent(EventType.STATE_ROOM_POWER_LEVELS) + .liveStateEvent(EventType.STATE_ROOM_POWER_LEVELS, "") .mapOptional { it.content.toModel() } .unwrap(), BiFunction { roomMembers, powerLevelsContent -> @@ -96,6 +97,7 @@ class RoomMemberListViewModel @AssistedInject constructor(@Assisted initialState .switchMap { membersSummary -> session.getLiveCryptoDeviceInfo(membersSummary.map { it.userId }) .asObservable() + .doOnError { Timber.e(it) } .map { deviceList -> // If any key change, emit the userIds list deviceList.groupBy { it.userId }.mapValues {