ArchiveMutator.kt

fun archiveMutator(
    scope: CoroutineScope,
    route: ArchiveRoute,
    repo: ArchiveRepository,
    appMutator: AppMutator,
): Mutator<Action, StateFlow<State>> = stateFlowMutator(
    scope = scope,
    initialState = State(...),
    started = SharingStarted.WhileSubscribed(stopTimeoutMillis = 2000),
    transform = { actions ->
        merge(
            appMutator.navRailStatusMutations(),
            actions.toMutationStream {
                when (val action = type()) {
                    is Action.Fetch -> action.flow.fetchMutations(repo = repo)
                    is Action.Navigate -> action.flow.map { it.navAction }.consumeWith(appMutator)
                    is Action.UpdateListState -> action.flow.updateListStateMutations()
                    is Action.FilterChanged -> action.flow.filterChangedMutations()
                    is Action.ToggleFilter -> action.flow.filterToggleMutations()
                    is Action.GridSize -> action.flow.gridSizeMutations()
                }
            }
        ).monitorWhenActive(appMutator)
    }
)