@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