@FlowPreview inline fun <reified T : Any> ServerRequest.bodyToFlow(batchSize: Int = 1): Flow<T>
Coroutines kotlinx.coroutines.flow.Flow based variant of ServerRequest.bodyToFlux.
Backpressure is controlled by batchSize parameter that controls the size of in-flight elements and org.reactivestreams.Subscription.request size.
Author
Sebastien Deleuze
Since
5.2