diff --git a/vector/src/debug/java/im/vector/app/features/debug/settings/DebugPrivateSettingsViewModel.kt b/vector/src/debug/java/im/vector/app/features/debug/settings/DebugPrivateSettingsViewModel.kt index f4ff4da163..624c46556a 100644 --- a/vector/src/debug/java/im/vector/app/features/debug/settings/DebugPrivateSettingsViewModel.kt +++ b/vector/src/debug/java/im/vector/app/features/debug/settings/DebugPrivateSettingsViewModel.kt @@ -25,7 +25,6 @@ import im.vector.app.core.di.hiltMavericksViewModelFactory import im.vector.app.core.platform.EmptyViewEvents import im.vector.app.core.platform.VectorViewModel import im.vector.app.features.settings.VectorDataStore -import kotlinx.coroutines.flow.onEach import kotlinx.coroutines.launch class DebugPrivateSettingsViewModel @AssistedInject constructor( @@ -45,12 +44,10 @@ class DebugPrivateSettingsViewModel @AssistedInject constructor( } private fun observeVectorDataStore() { - vectorDataStore.forceDialPadDisplayFlow.onEach { - setState { - copy( - dialPadVisible = it - ) - } + vectorDataStore.forceDialPadDisplayFlow.setOnEach { + copy( + dialPadVisible = it + ) } } diff --git a/vector/src/main/java/im/vector/app/features/home/HomeDetailViewModel.kt b/vector/src/main/java/im/vector/app/features/home/HomeDetailViewModel.kt index 84fd8e06ee..e6eaa7e0ec 100644 --- a/vector/src/main/java/im/vector/app/features/home/HomeDetailViewModel.kt +++ b/vector/src/main/java/im/vector/app/features/home/HomeDetailViewModel.kt @@ -38,7 +38,6 @@ import im.vector.app.features.invite.showInvites import im.vector.app.features.settings.VectorDataStore import im.vector.app.features.ui.UiStateRepository import kotlinx.coroutines.Dispatchers -import kotlinx.coroutines.flow.collect import kotlinx.coroutines.flow.distinctUntilChanged import kotlinx.coroutines.flow.filterIsInstance import kotlinx.coroutines.flow.flatMapLatest @@ -104,19 +103,16 @@ class HomeDetailViewModel @AssistedInject constructor( private var forceDialPad = false private fun observeDataStore() { - viewModelScope.launch { - vectorDataStore.pushCounterFlow.collect { nbOfPush -> - setState { - copy( - pushCounter = nbOfPush - ) - } - } - vectorDataStore.forceDialPadDisplayFlow.collect { force -> - forceDialPad = force - updateShowDialPadTab() - } + vectorDataStore.pushCounterFlow.setOnEach { nbOfPush -> + copy( + pushCounter = nbOfPush + ) } + + vectorDataStore.forceDialPadDisplayFlow.onEach { force -> + forceDialPad = force + updateShowDialPadTab() + }.launchIn(viewModelScope) } override fun handle(action: HomeDetailAction) { diff --git a/vector/src/main/java/im/vector/app/features/home/room/detail/RoomDetailViewModel.kt b/vector/src/main/java/im/vector/app/features/home/room/detail/RoomDetailViewModel.kt index d846a1d1f8..3e1d9487f3 100644 --- a/vector/src/main/java/im/vector/app/features/home/room/detail/RoomDetailViewModel.kt +++ b/vector/src/main/java/im/vector/app/features/home/room/detail/RoomDetailViewModel.kt @@ -195,14 +195,10 @@ class RoomDetailViewModel @AssistedInject constructor( } private fun observeDataStore() { - viewModelScope.launch { - vectorDataStore.pushCounterFlow.collect { nbOfPush -> - setState { - copy( - pushCounter = nbOfPush - ) - } - } + vectorDataStore.pushCounterFlow.setOnEach { nbOfPush -> + copy( + pushCounter = nbOfPush + ) } }