Package io.servicetalk.http.api

Interface HttpClient

All Superinterfaces:

AsyncCloseable, AutoCloseable, GracefulAutoCloseable, HttpRequester, HttpRequestFactory, ListenableAsyncCloseable

public interface HttpClient
extends HttpRequester

Provides a means to issue requests against HTTP service. The implementation is free to maintain a collection of HttpConnection instances and distribute calls to HttpRequester.request(HttpRequest) amongst this collection.

Method Summary

Modifier and Type	Method	Description
default BlockingHttpClient	asBlockingClient()	Convert this HttpClient to the BlockingHttpClient API.
default BlockingStreamingHttpClient	asBlockingStreamingClient()	Convert this HttpClient to the BlockingStreamingHttpClient API.
StreamingHttpClient	asStreamingClient()	Convert this HttpClient to the StreamingHttpClient API.
Single<ReservedHttpConnection>	reserveConnection(HttpRequestMetaData metaData)	Reserve an HttpConnection based on provided HttpRequestMetaData.

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

closeAsync, closeAsyncGracefully

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

close, closeGracefully, executionContext, httpResponseFactory, request

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

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

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

onClose, onClosing

Method Details

reserveConnection

Single<ReservedHttpConnection> reserveConnection(HttpRequestMetaData metaData)

Reserve an HttpConnection based on provided HttpRequestMetaData.

If a new connection should be opened instead of potentially reusing an already established one, the HttpContextKeys.HTTP_FORCE_NEW_CONNECTION must be set.

Parameters:

metaData - Allows the underlying layers to know what HttpConnections are valid to reserve for future requests with the same HttpRequestMetaData. For example this may provide some insight into shard or other info.

Returns:

a Single that provides the ReservedHttpConnection upon completion.

See Also:

• HttpContextKeys.HTTP_FORCE_NEW_CONNECTION

asStreamingClient

StreamingHttpClient asStreamingClient()

Convert this HttpClient to the StreamingHttpClient API.

Returns:

a StreamingHttpClient representation of this HttpClient.

asBlockingStreamingClient

default BlockingStreamingHttpClient asBlockingStreamingClient()

Convert this HttpClient to the BlockingStreamingHttpClient API.

Returns:

a BlockingStreamingHttpClient representation of this HttpClient.

asBlockingClient

default BlockingHttpClient asBlockingClient()

Convert this HttpClient to the BlockingHttpClient API.

Returns:

a BlockingHttpClient representation of this HttpClient.