BatchExecutionPolicy

class BatchExecutionPolicy(val concurrency: Int = 128, val prefetch: Int = 4)

Constructors

Link copied to clipboard
constructor(concurrency: Int = 128, prefetch: Int = 4)

Properties

Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun <T : Any, R : Any> apply(source: Flux<T>, mapper: (T) -> Publisher<out R>): Flux<R>