vrr/Flocon
2
0
Fork 0
mirror of https://github.com/openflocon/Flocon.git synced 2026-05-22 06:13:52 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Refactor domainFlows to a proper StateFlow

Browse source 
Replace mutable side-effect property with a dedicated StateFlow
for more robust and predictable reactive state management.
This commit is contained in:
Adit Lal 2026-02-18 21:48:10 +05:30
parent d24598366b
commit 865e7efcea
1 changed files with 11 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

18
FloconDesktop/composeApp/src/commonMain/kotlin/io/github/openflocon/flocondesktop/features/adbcommander/AdbCommanderViewModel.kt
View file

@ -55,16 +55,20 @@ class AdbCommanderViewModel(
private val localState = MutableStateFlow(AdbCommanderUiState())
private var flowExecutionJob: Job? = null
private var domainFlows: List<AdbFlowDomainModel> = emptyList()
private val domainFlows: StateFlow<List<AdbFlowDomainModel>> = observeFlowsUseCase()
.flowOn(dispatcherProvider.viewModel)
.stateIn(
scope = viewModelScope,
started = SharingStarted.WhileSubscribed(5_000),
initialValue = emptyList(),
)
val uiState: StateFlow<AdbCommanderUiState> = combine(
localState,
observeSavedCommandsUseCase().mapLatest { list -> list.map { it.toUiModel() } },
observeCommandHistoryUseCase().mapLatest { list -> list.map { it.toUiModel() } },
observeFlowsUseCase().mapLatest { list ->
domainFlows = list
list.map { it.toUiModel() }
},
domainFlows.mapLatest { list -> list.map { it.toUiModel() } },
) { local, savedCommands, history, flows ->
local.copy(
savedCommands = savedCommands,
@ -189,7 +193,7 @@ class AdbCommanderViewModel(
// Flow editor
fun onShowFlowEditor(flowId: Long? = null) {
if (flowId != null) {
val flow = domainFlows.find { it.id == flowId }
val flow = domainFlows.value.find { it.id == flowId }
localState.update {
it.copy(
showFlowEditor = true,
@ -333,7 +337,7 @@ class AdbCommanderViewModel(
}
fun onExecuteFlow(flowId: Long) {
val flow = domainFlows.find { it.id == flowId } ?: return
val flow = domainFlows.value.find { it.id == flowId } ?: return
flowExecutionJob?.cancel()
localState.update { it.copy(selectedTab = AdbCommanderTab.Runner) }