diff --git a/app/src/main/java/org/thoughtcrime/securesms/database/RxDatabaseObserver.kt b/app/src/main/java/org/thoughtcrime/securesms/database/RxDatabaseObserver.kt index 26d6d1a5de..45eac30b65 100644 --- a/app/src/main/java/org/thoughtcrime/securesms/database/RxDatabaseObserver.kt +++ b/app/src/main/java/org/thoughtcrime/securesms/database/RxDatabaseObserver.kt @@ -37,7 +37,7 @@ object RxDatabaseObserver { @Suppress("RedundantUnitExpression") private fun notificationProfilesFlowable(): Flowable { return Flowable.combineLatest( - Flowable.interval(0, 30, TimeUnit.SECONDS), + Flowable.interval(0, 30, TimeUnit.SECONDS).onBackpressureLatest(), databaseFlowable { AppDependencies.databaseObserver.registerNotificationProfileObserver(it) } ) { _, _ -> Unit } }