io.servicetalk.http.api

Interface BlockingStreamingHttpClient

All Superinterfaces:

java.lang.AutoCloseable, BlockingStreamingHttpRequester, BlockingStreamingHttpRequestFactory, GracefulAutoCloseable

public interface BlockingStreamingHttpClient
extends BlockingStreamingHttpRequester

The equivalent of StreamingHttpClient but with synchronous/blocking APIs instead of asynchronous APIs.

Method Summary

Modifier and Type	Method and Description
default BlockingHttpClient	asBlockingClient() Convert this BlockingStreamingHttpClient to the BlockingHttpClient API.
default HttpClient	asClient() Convert this BlockingStreamingHttpClient to the HttpClient API.
StreamingHttpClient	asStreamingClient() Convert this BlockingStreamingHttpClient to the StreamingHttpClient API.
BlockingStreamingHttpResponse	request(BlockingStreamingHttpRequest request) Send a request.
ReservedBlockingStreamingHttpConnection	reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData) Reserve a BlockingStreamingHttpConnection based on provided HttpRequestMetaData.
ReservedBlockingStreamingHttpConnection	reserveConnection(HttpRequestMetaData metaData) Reserve a BlockingStreamingHttpConnection based on provided HttpRequestMetaData.

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

close, executionContext, httpResponseFactory, request

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

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

Methods inherited from interface io.servicetalk.concurrent.GracefulAutoCloseable

closeGracefully

Method Detail

request

BlockingStreamingHttpResponse request(BlockingStreamingHttpRequest request)
                               throws java.lang.Exception

Send a request.

Parameters:

request - the request to send.

Returns:

The response.

Throws:

java.lang.Exception - if an exception occurs during the request processing.

reserveConnection

ReservedBlockingStreamingHttpConnection reserveConnection(HttpRequestMetaData metaData)
                                                   throws java.lang.Exception

Reserve a BlockingStreamingHttpConnection based on provided HttpRequestMetaData.

Parameters:

metaData - Allows the underlying layers to know what BlockingStreamingHttpConnections 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 ReservedBlockingStreamingHttpConnection.

Throws:

java.lang.Exception - if a exception occurs during the reservation process.

reserveConnection

ReservedBlockingStreamingHttpConnection reserveConnection(HttpExecutionStrategy strategy,
                                                          HttpRequestMetaData metaData)
                                                   throws java.lang.Exception

Reserve a BlockingStreamingHttpConnection based on provided HttpRequestMetaData.

Parameters:

strategy - HttpExecutionStrategy to use.

metaData - Allows the underlying layers to know what BlockingStreamingHttpConnections 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 ReservedBlockingStreamingHttpConnection.

Throws:

java.lang.Exception - if a exception occurs during the reservation process.

asStreamingClient

StreamingHttpClient asStreamingClient()

Convert this BlockingStreamingHttpClient to the StreamingHttpClient API.

Note that the resulting StreamingHttpClient may still be subject to any blocking, in memory aggregation, and other behavior as this BlockingStreamingHttpClient.

Returns:

a StreamingHttpClient representation of this BlockingStreamingHttpClient.

asClient

default HttpClient asClient()

Convert this BlockingStreamingHttpClient to the HttpClient API.

Note that the resulting HttpClient may still be subject to any blocking, in memory aggregation, and other behavior as this BlockingStreamingHttpClient.

Returns:

a HttpClient representation of this BlockingStreamingHttpClient.

asBlockingClient

default BlockingHttpClient asBlockingClient()

Convert this BlockingStreamingHttpClient to the BlockingHttpClient API.

Note that the resulting BlockingHttpClient may still be subject to in memory aggregation and other behavior as this BlockingStreamingHttpClient.

Returns:

a BlockingHttpClient representation of this BlockingStreamingHttpClient.