throughBulkhead

fun <T> Flow<T>.throughBulkhead(bulkhead: Bulkhead): Flow<T>(source)

Protects collection of this Flow with a Bulkhead: the whole collection counts as a single call against the bulkhead's concurrency limit.