wow-webflux/me.ahoo.wow.webflux.route.policy/BatchExecutionPolicy

BatchExecutionPolicy

class BatchExecutionPolicy(val concurrency: Int = 1, val prefetch: Int = 1)

Constructors

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

Properties

Link copied to clipboard
Link copied to clipboard
val prefetch: Int

Functions

Link copied to clipboard
fun <T : Any, R : Any> apply(source: Flux<T>, mapper: (T) -> Publisher<out R>): Flux<R>
Generated by Dokka
© 2026 Copyright