mobiuskt-coroutines/kt.mobius.flow/ExecutionPolicy

ExecutionPolicy

interface ExecutionPolicy

Defines execution behavior of handler functions added to a subtypeEffectHandler.

Inheritors

Types

Concurrent

class Concurrent(limit: Int) : ExecutionPolicy

Handle Effects concurrently up to the provided limit, defaulting to DEFAULT_CONCURRENCY.

Latest

object Latest : ExecutionPolicy

Handle only the most recent Effect, cancelling the previous operation when a new Effect is dispatched.

Sequential

object Sequential : ExecutionPolicy

Handle Effects one at a time, completing each in order before handling the next.

ThrottleLatest

class ThrottleLatest(window: Duration) : ExecutionPolicy

Immediately handle the first Effect, delaying any new effects by the provided window. When a new Effect is dispatched within the window, it is dispatched after the window elapses and the previous handler is canceled if still running.

Functions

execute

abstract fun <F, E> execute(transform: suspend FlowCollector<E>.(effect: F) -> Unit, effects: Flow<F>): Flow<E>