Skip to content

Commit 34e8cf8

Browse files
committed
Improve Rx sequence regarding listener
1 parent 6691edb commit 34e8cf8

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

vector/src/main/java/im/vector/app/features/home/ShortcutsHandler.kt

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,17 +54,15 @@ class ShortcutsHandler @Inject constructor(
5454
hasPinCode = pinCodeStore.getEncodedPin() != null
5555

5656
val session = activeSessionHolder.getSafeActiveSession() ?: return Disposables.empty()
57-
pinCodeStore.addListener(this)
5857
return session.getRoomSummariesLive(
5958
roomSummaryQueryParams {
6059
memberships = listOf(Membership.JOIN)
6160
},
6261
sortOrder = RoomSortOrder.PRIORITY_AND_ACTIVITY
6362
)
6463
.asObservable()
65-
.doOnDispose {
66-
pinCodeStore.removeListener(this)
67-
}
64+
.doOnSubscribe { pinCodeStore.addListener(this) }
65+
.doFinally { pinCodeStore.removeListener(this) }
6866
.subscribe { rooms ->
6967
// Remove dead shortcuts (i.e. deleted rooms)
7068
removeDeadShortcut(rooms.map { it.roomId })

0 commit comments

Comments
 (0)