From f098d6cf5b3d8eb384d93d61d7b8a09ac13939ff Mon Sep 17 00:00:00 2001 From: Benoit Marty Date: Sat, 1 Feb 2020 11:45:45 +0100 Subject: [PATCH] Add startWith --- .../src/main/java/im/vector/matrix/rx/RxRoom.kt | 1 + .../src/main/java/im/vector/matrix/rx/RxSession.kt | 1 + 2 files changed, 2 insertions(+) diff --git a/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxRoom.kt b/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxRoom.kt index 6ca0b55fd7..42720fcaa5 100644 --- a/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxRoom.kt +++ b/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxRoom.kt @@ -93,6 +93,7 @@ class RxRoom(private val room: Room, private val session: Session) { // TODO Do it only for room members of the room (switchMap) val cryptoDeviceInfoObservable = session.getLiveCryptoDeviceInfo().asObservable() + .startWith(emptyList()) return Observable .combineLatest, List, List>( diff --git a/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxSession.kt b/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxSession.kt index cbe47472c4..0bddf8b685 100644 --- a/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxSession.kt +++ b/matrix-sdk-android-rx/src/main/java/im/vector/matrix/rx/RxSession.kt @@ -42,6 +42,7 @@ class RxSession(private val session: Session) { .startWith(session.getRoomSummaries(queryParams)) val cryptoDeviceInfoObservable = session.getLiveCryptoDeviceInfo().asObservable() + .startWith(emptyList()) return Observable .combineLatest, List, List>(