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

Concurrent

class Concurrent(limit: Int) : ExecutionPolicy

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

Parameters

limit

The number of effects that that can be handled concurrently, defaulting to DEFAULT_CONCURRENCY.

Constructors

Link copied to clipboard
constructor(limit: Int)

Types

Link copied to clipboard

Functions

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