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 ofHttpRequesterbut that acceptsStreamingHttpRequestand returnsStreamingHttpResponse.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description HttpExecutionContextexecutionContext()Get theHttpExecutionContextused during construction of this object.StreamingHttpResponseFactoryhttpResponseFactory()Get aStreamingHttpResponseFactory.Single<StreamingHttpResponse>request(HttpExecutionStrategy strategy, StreamingHttpRequest request)Send arequestusing 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 arequestusing the specifiedstrategy.- Parameters:
strategy-HttpExecutionStrategyto use for executing the request.request- the request to send.- Returns:
- The response.
-
executionContext
HttpExecutionContext executionContext()
Get theHttpExecutionContextused 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
HttpExecutionContextused during construction of this object.
-
httpResponseFactory
StreamingHttpResponseFactory httpResponseFactory()
Get aStreamingHttpResponseFactory.- Returns:
- a
StreamingHttpResponseFactory.
-
-