Package io.servicetalk.http.api
Interface StreamingHttpRequester
-
- All Superinterfaces:
AsyncCloseable
,ListenableAsyncCloseable
,StreamingHttpRequestFactory
- All Known Subinterfaces:
FilterableReservedStreamingHttpConnection
,FilterableStreamingHttpClient
,FilterableStreamingHttpConnection
,FilterableStreamingHttpLoadBalancedConnection
,ReservedStreamingHttpConnection
,StreamingHttpClient
,StreamingHttpConnection
- All Known Implementing Classes:
ReservedStreamingHttpConnectionFilter
,StreamingHttpClientFilter
,StreamingHttpConnectionFilter
public interface StreamingHttpRequester extends StreamingHttpRequestFactory, ListenableAsyncCloseable
The equivalent ofHttpRequester
but that acceptsStreamingHttpRequest
and returnsStreamingHttpResponse
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description HttpExecutionContext
executionContext()
Get theHttpExecutionContext
used during construction of this object.StreamingHttpResponseFactory
httpResponseFactory()
Get aStreamingHttpResponseFactory
.Single<StreamingHttpResponse>
request(HttpExecutionStrategy strategy, StreamingHttpRequest request)
Send arequest
using the specifiedstrategy
.-
Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable
closeAsync, closeAsyncGracefully
-
Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable
onClose
-
-
-
-
Method Detail
-
request
Single<StreamingHttpResponse> request(HttpExecutionStrategy strategy, StreamingHttpRequest request)
Send arequest
using the specifiedstrategy
.- Parameters:
strategy
-HttpExecutionStrategy
to use for executing the request.request
- the request to send.- Returns:
- The response.
-
executionContext
HttpExecutionContext executionContext()
Get theHttpExecutionContext
used during construction of this object.Note that the
ExecutionContext.ioExecutor()
will not necessarily be associated with a specific thread unless that was how this object was built.- Returns:
- the
HttpExecutionContext
used during construction of this object.
-
httpResponseFactory
StreamingHttpResponseFactory httpResponseFactory()
Get aStreamingHttpResponseFactory
.- Returns:
- a
StreamingHttpResponseFactory
.
-
-