Package io.servicetalk.http.api

Interface StreamingHttpClient

All Superinterfaces:

AsyncCloseable, java.lang.AutoCloseable, FilterableStreamingHttpClient, GracefulAutoCloseable, ListenableAsyncCloseable, StreamingHttpRequester, StreamingHttpRequestFactory

public interface StreamingHttpClient
extends FilterableStreamingHttpClient, GracefulAutoCloseable

The equivalent of HttpClient but that accepts StreamingHttpRequest and returns StreamingHttpResponse.

Method Summary

Modifier and Type	Method	Description
BlockingHttpClient	asBlockingClient()	Convert this StreamingHttpClient to the BlockingHttpClient API.
BlockingStreamingHttpClient	asBlockingStreamingClient()	Convert this StreamingHttpClient to the BlockingStreamingHttpClient API.
HttpClient	asClient()	Convert this StreamingHttpClient to the HttpClient API.
default void	close()
default void	closeGracefully()	Used to close/shutdown a resource, similar to AutoCloseable.close(), but attempts to cleanup state before abruptly closing.
Single<StreamingHttpResponse>	request(StreamingHttpRequest request)	Send a request.
Single<ReservedStreamingHttpConnection>	reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData)	Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.
Single<ReservedStreamingHttpConnection>	reserveConnection(HttpRequestMetaData metaData)	Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.

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

closeAsync, closeAsyncGracefully

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

onClose

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

executionContext, httpResponseFactory, request

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

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

Method Detail

request

Single<StreamingHttpResponse> request(StreamingHttpRequest request)

Send a request.

Parameters:

request - the request to send.

Returns:

The response.

reserveConnection

Single<ReservedStreamingHttpConnection> reserveConnection(HttpRequestMetaData metaData)

Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.

Parameters:

metaData - Allows the underlying layers to know what StreamingHttpConnections 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 ReservedStreamingHttpConnection upon completion.

reserveConnection

Single<ReservedStreamingHttpConnection> reserveConnection(HttpExecutionStrategy strategy,
                                                          HttpRequestMetaData metaData)

Description copied from interface: FilterableStreamingHttpClient

Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.

Specified by:

reserveConnection in interface FilterableStreamingHttpClient

Parameters:

strategy - HttpExecutionStrategy to use.

metaData - Allows the underlying layers to know what StreamingHttpConnections 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 ReservedStreamingHttpConnection upon completion.

asClient

HttpClient asClient()

Convert this StreamingHttpClient to the HttpClient API.

This API is provided for convenience. It is recommended that filters are implemented using the StreamingHttpClient asynchronous API for maximum portability.

Returns:

a HttpClient representation of this StreamingHttpRequester.

asBlockingStreamingClient

BlockingStreamingHttpClient asBlockingStreamingClient()

Convert this StreamingHttpClient to the BlockingStreamingHttpClient API.

This API is provided for convenience for a more familiar sequential programming model. It is recommended that filters are implemented using the StreamingHttpClient asynchronous API for maximum portability.

Returns:

a BlockingStreamingHttpClient representation of this StreamingHttpClient.

asBlockingClient

BlockingHttpClient asBlockingClient()

Convert this StreamingHttpClient to the BlockingHttpClient API.

This API is provided for convenience for a more familiar sequential programming model. It is recommended that filters are implemented using the StreamingHttpClient asynchronous API for maximum portability.

Returns:

a BlockingHttpClient representation of this StreamingHttpClient.

close

default void close()
            throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

closeGracefully

default void closeGracefully()
                      throws java.lang.Exception

Description copied from interface: GracefulAutoCloseable

Used to close/shutdown a resource, similar to AutoCloseable.close(), but attempts to cleanup state before abruptly closing. This provides a hint that implementations can use to stop accepting new work and finish in flight work. This method is implemented on a "best effort" basis and may be equivalent to AutoCloseable.close().

Note: Implementations may or may not apply a timeout for this operation to complete, if a caller does not want to wait indefinitely, and are unsure if the implementation applies a timeout, it is advisable to apply a timeout and force a call to AutoCloseable.close().

Specified by:

closeGracefully in interface GracefulAutoCloseable

Throws:

java.lang.Exception - if graceful closure failed.