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 of HttpRequester but that accepts StreamingHttpRequest and returns StreamingHttpResponse.

Method Summary

Modifier and Type	Method and Description
HttpExecutionContext	executionContext() Get the HttpExecutionContext used during construction of this object.
StreamingHttpResponseFactory	httpResponseFactory() Get a StreamingHttpResponseFactory.
Single<StreamingHttpResponse>	request(HttpExecutionStrategy strategy, StreamingHttpRequest request) Send a request using the specified strategy.

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequestFactory

connect, delete, get, head, newRequest, options, patch, post, trace

Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable

onClose

Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable

closeAsync, closeAsyncGracefully

Method Detail

request

Single<StreamingHttpResponse> request(HttpExecutionStrategy strategy,
                                      StreamingHttpRequest request)

Send a request using the specified strategy.

Parameters:

strategy - HttpExecutionStrategy to use for executing the request.

request - the request to send.

Returns:

The response.

executionContext

HttpExecutionContext executionContext()

Get the HttpExecutionContext 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 a StreamingHttpResponseFactory.

Returns:

a StreamingHttpResponseFactory.