spring-framework / org.springframework.web.reactive.function.server / bodyToFlow

bodyToFlow

@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