datasourcex-util/com.caplin.integration.datasourcex.util.flow/bufferingDebounce

bufferingDebounce

fun <T> Flow<T>.bufferingDebounce(timeoutMillis: Long): Flow<List<T>>(source)

Buffers all elements emitted until there is a period of no emissions greater than timeoutMillis, then emits all buffered elements within a List.

If the upstream Flow completes, any remaining elements are emitted immediately.

fun <T> Flow<T>.bufferingDebounce(timeout: Duration): Flow<List<T>>(source)

Buffers all elements emitted until there is a period of no emissions greater than timeout, then emits all buffered elements within a List.

If the upstream Flow completes, any remaining elements are emitted immediately.