mobiuskt-coroutines/kt.mobius.flow/ExecutionPolicy/ThrottleLatest

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.

Constructors

ThrottleLatest

constructor(window: Duration)

Functions

execute

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