From d436d3b8d4d7d5d318f1e277fb882e1b37902b7a Mon Sep 17 00:00:00 2001 From: Valere Date: Sun, 2 Feb 2020 00:41:36 +0100 Subject: [PATCH] Move rx logs to verbose --- .../main/java/im/vector/matrix/rx/RxRoom.kt | 18 +++++++++--------- .../main/java/im/vector/matrix/rx/RxSession.kt | 4 ++-- 2 files changed, 11 insertions(+), 11 deletions(-) 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 7779bd1a0e..7f3675cb39 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 @@ -42,7 +42,7 @@ class RxRoom(private val room: Room, private val session: Session) { val summaryObservable = room.getRoomSummaryLive() .asObservable() .startWith(room.roomSummary().toOptional()) - .doOnNext { Timber.d("RX: summary emitted for: ${it.getOrNull()?.roomId}") } + .doOnNext { Timber.v("RX: summary emitted for: ${it.getOrNull()?.roomId}") } val memberIdsChangeObservable = summaryObservable .map { @@ -56,7 +56,7 @@ class RxRoom(private val room: Room, private val session: Session) { } }.orEmpty() }.distinctUntilChanged() - .doOnNext { Timber.d("RX: memberIds emitted. Size: ${it.size}") } + .doOnNext { Timber.v("RX: memberIds emitted. Size: ${it.size}") } // Observe the device info of the users in the room val cryptoDeviceInfoObservable = memberIdsChangeObservable @@ -68,9 +68,9 @@ class RxRoom(private val room: Room, private val session: Session) { membersIds } .startWith(membersIds) - .doOnNext { Timber.d("RX: CryptoDeviceInfo emitted. Size: ${it.size}") } + .doOnNext { Timber.v("RX: CryptoDeviceInfo emitted. Size: ${it.size}") } } - .doOnNext { Timber.d("RX: cryptoDeviceInfo emitted 2. Size: ${it.size}") } + .doOnNext { Timber.v("RX: cryptoDeviceInfo emitted 2. Size: ${it.size}") } val roomEncryptionTrustLevelObservable = cryptoDeviceInfoObservable .map { userIds -> @@ -80,7 +80,7 @@ class RxRoom(private val room: Room, private val session: Session) { session.getCrossSigningService().getTrustLevelForUsers(userIds).toOptional() } } - .doOnNext { Timber.d("RX: roomEncryptionTrustLevel emitted: ${it.getOrNull()?.name}") } + .doOnNext { Timber.v("RX: roomEncryptionTrustLevel emitted: ${it.getOrNull()?.name}") } return Observable .combineLatest, Optional, Optional>( @@ -92,18 +92,18 @@ class RxRoom(private val room: Room, private val session: Session) { ).toOptional() } ) - .doOnNext { Timber.d("RX: final room summary emitted for ${it.getOrNull()?.roomId}") } + .doOnNext { Timber.v("RX: final room summary emitted for ${it.getOrNull()?.roomId}") } } fun liveRoomMembers(queryParams: RoomMemberQueryParams): Observable> { val roomMembersObservable = room.getRoomMembersLive(queryParams).asObservable() .startWith(room.getRoomMembers(queryParams)) - .doOnNext { Timber.d("RX: room members emitted. Size: ${it.size}") } + .doOnNext { Timber.v("RX: room members emitted. Size: ${it.size}") } // TODO Do it only for room members of the room (switchMap) val cryptoDeviceInfoObservable = session.getLiveCryptoDeviceInfo().asObservable() .startWith(emptyList()) - .doOnNext { Timber.d("RX: cryptoDeviceInfo emitted. Size: ${it.size}") } + .doOnNext { Timber.v("RX: cryptoDeviceInfo emitted. Size: ${it.size}") } return Observable .combineLatest, List, List>( @@ -122,7 +122,7 @@ class RxRoom(private val room: Room, private val session: Session) { } } ) - .doOnNext { Timber.d("RX: final room members emitted. Size: ${it.size}") } + .doOnNext { Timber.v("RX: final room members emitted. Size: ${it.size}") } } fun liveAnnotationSummary(eventId: String): Observable> { 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 1f5ff9422c..88f8e82843 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 @@ -41,11 +41,11 @@ class RxSession(private val session: Session) { fun liveRoomSummaries(queryParams: RoomSummaryQueryParams): Observable> { val summariesObservable = session.getRoomSummariesLive(queryParams).asObservable() .startWith(session.getRoomSummaries(queryParams)) - .doOnNext { Timber.d("RX: summaries emitted: size: ${it.size}") } + .doOnNext { Timber.v("RX: summaries emitted: size: ${it.size}") } val cryptoDeviceInfoObservable = session.getLiveCryptoDeviceInfo().asObservable() .startWith(emptyList()) - .doOnNext { Timber.d("RX: crypto device info emitted: size: ${it.size}") } + .doOnNext { Timber.v("RX: crypto device info emitted: size: ${it.size}") } return Observable .combineLatest, List, List>(