udfWithFlows.kt

    fun <Action : Any, State : Any> Flow<Action>.toStateStream(
        initialState: State,
        transform: (Flow<Action>) -> Flow<State.() -> State>
    ): Flow<State> = transform(this)
        .scan(initialState) { state, mutation ->
            mutation(state)
        }