sendAndHandle
fun <T> Flow<HttpRequest>.sendAndHandle(bodyHandler: HttpResponse.BodyHandler<T>, concurrency: Int = 1, httpClient: HttpClient = DefaultHttpClient): Flow<HttpResponse<T>>
Sends each HTTP request in the flow and returns a flow of the HTTP responses.
Return
A flow of HTTP responses.
Parameters
bodyHandler
The body handler to process the HTTP response body.
concurrency
The maximum number of concurrent requests.
httpClient
The HTTP client used to send the requests.
fun <T> Flow<HttpRequest>.sendAndHandle(concurrency: Int = 1, httpClient: HttpClient = DefaultHttpClient, handle: CoroutineScope.() -> HttpResponse.BodyHandler<T>): Flow<HttpResponse<T>>
Sends each HTTP request in the flow and returns a flow of the HTTP responses.
Return
A flow of HTTP responses.
Parameters
concurrency
The maximum number of concurrent requests.
httpClient
The HTTP client used to send the requests.
handle
A function that returns a body handler to process the HTTP response body.