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

bodyToFlow

@FlowPreview inline fun <reified T : Any> ClientResponse.bodyToFlow(batchSize: Int = 1): Flow<T>

Coroutines kotlinx.coroutines.flow.Flow based variant of ClientResponse.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

@FlowPreview inline fun <reified T : Any> ResponseSpec.bodyToFlow(batchSize: Int = 1): Flow<T>

Coroutines kotlinx.coroutines.flow.Flow based variant of WebClient.ResponseSpec.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