Package io.servicetalk.http.api

Class HttpApiConversions

java.lang.Object

io.servicetalk.http.api.HttpApiConversions

public final class HttpApiConversions
extends java.lang.Object

Conversion routines to StreamingHttpService.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	HttpApiConversions.ServiceAdapterHolder	A holder for StreamingHttpService that adapts another service to the streaming programming model.

Method Summary

Modifier and Type	Method	Description
static boolean	isPayloadEmpty(HttpMetaData metadata)	Checks whether a request/response payload body is empty.
static boolean	isSafeToAggregate(HttpMetaData metadata)	Checks whether a request/response payload is safe to aggregate, which may allow for writing a `content-length` header.
static boolean	mayHaveTrailers(HttpMetaData metadata)	Checks whether a request/response payload may have trailers.
static BlockingHttpClient	toBlockingClient(StreamingHttpClient original, HttpExecutionStrategyInfluencer influencer)	Convert from StreamingHttpClient to BlockingHttpClient.
static BlockingHttpConnection	toBlockingConnection(StreamingHttpConnection original, HttpExecutionStrategyInfluencer influencer)	Convert from StreamingHttpConnection to BlockingHttpConnection.
static BlockingHttpService	toBlockingHttpService(StreamingHttpService service)	Convert from a StreamingHttpService to a BlockingHttpService.
static BlockingStreamingHttpClient	toBlockingStreamingClient(StreamingHttpClient original, HttpExecutionStrategyInfluencer influencer)	Convert from StreamingHttpClient to BlockingStreamingHttpClient.
static BlockingStreamingHttpConnection	toBlockingStreamingConnection(StreamingHttpConnection original, HttpExecutionStrategyInfluencer influencer)	Convert from StreamingHttpConnection to BlockingStreamingHttpConnection.
static BlockingStreamingHttpService	toBlockingStreamingHttpService(StreamingHttpService service)	Convert from a StreamingHttpService to a BlockingStreamingHttpService.
static HttpClient	toClient(StreamingHttpClient original, HttpExecutionStrategyInfluencer influencer)	Convert from StreamingHttpClient to HttpClient.
static HttpConnection	toConnection(StreamingHttpConnection original, HttpExecutionStrategyInfluencer influencer)	Convert from StreamingHttpConnection to HttpConnection.
static HttpService	toHttpService(StreamingHttpService service)	Convert from a StreamingHttpService to a HttpService.
static ReservedBlockingHttpConnection	toReservedBlockingConnection(ReservedStreamingHttpConnection original, HttpExecutionStrategyInfluencer influencer)	Convert from ReservedStreamingHttpConnection to ReservedBlockingHttpConnection.
static ReservedBlockingStreamingHttpConnection	toReservedBlockingStreamingConnection(ReservedStreamingHttpConnection original, HttpExecutionStrategyInfluencer influencer)	Convert from ReservedStreamingHttpConnection to ReservedBlockingStreamingHttpConnection.
static ReservedHttpConnection	toReservedConnection(ReservedStreamingHttpConnection original, HttpExecutionStrategyInfluencer influencer)	Convert from ReservedStreamingHttpConnection to ReservedHttpConnection.
static HttpApiConversions.ServiceAdapterHolder	toStreamingHttpService(BlockingHttpService service, HttpExecutionStrategyInfluencer influencer)	Convert from a BlockingStreamingHttpService to a StreamingHttpService.
static HttpApiConversions.ServiceAdapterHolder	toStreamingHttpService(BlockingStreamingHttpService service, HttpExecutionStrategyInfluencer influencer)	Convert from a BlockingStreamingHttpService to a StreamingHttpService.
static HttpApiConversions.ServiceAdapterHolder	toStreamingHttpService(HttpService service, HttpExecutionStrategyInfluencer influencer)	Convert from a HttpService to a StreamingHttpService.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toReservedConnection

public static ReservedHttpConnection toReservedConnection(ReservedStreamingHttpConnection original,
                                                          HttpExecutionStrategyInfluencer influencer)

Convert from ReservedStreamingHttpConnection to ReservedHttpConnection.

Parameters:

original - ReservedStreamingHttpConnection to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned ReservedHttpConnection

Returns:

The conversion result.

toReservedBlockingConnection

public static ReservedBlockingHttpConnection toReservedBlockingConnection(ReservedStreamingHttpConnection original,
                                                                          HttpExecutionStrategyInfluencer influencer)

Convert from ReservedStreamingHttpConnection to ReservedBlockingHttpConnection.

Parameters:

original - ReservedStreamingHttpConnection to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned ReservedBlockingHttpConnection

Returns:

The conversion result.

toReservedBlockingStreamingConnection

public static ReservedBlockingStreamingHttpConnection toReservedBlockingStreamingConnection(ReservedStreamingHttpConnection original,
                                                                                            HttpExecutionStrategyInfluencer influencer)

Convert from ReservedStreamingHttpConnection to ReservedBlockingStreamingHttpConnection.

Parameters:

original - ReservedStreamingHttpConnection to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned ReservedBlockingStreamingHttpConnection

Returns:

The conversion result.

toConnection

public static HttpConnection toConnection(StreamingHttpConnection original,
                                          HttpExecutionStrategyInfluencer influencer)

Convert from StreamingHttpConnection to HttpConnection.

Parameters:

original - StreamingHttpConnection to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned HttpConnection

Returns:

The conversion result.

toBlockingConnection

public static BlockingHttpConnection toBlockingConnection(StreamingHttpConnection original,
                                                          HttpExecutionStrategyInfluencer influencer)

Convert from StreamingHttpConnection to BlockingHttpConnection.

Parameters:

original - StreamingHttpConnection to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned BlockingHttpConnection

Returns:

The conversion result.

toBlockingStreamingConnection

public static BlockingStreamingHttpConnection toBlockingStreamingConnection(StreamingHttpConnection original,
                                                                            HttpExecutionStrategyInfluencer influencer)

Convert from StreamingHttpConnection to BlockingStreamingHttpConnection.

Parameters:

original - StreamingHttpConnection to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned BlockingStreamingHttpConnection

Returns:

The conversion result.

toClient

public static HttpClient toClient(StreamingHttpClient original,
                                  HttpExecutionStrategyInfluencer influencer)

Convert from StreamingHttpClient to HttpClient.

Parameters:

original - StreamingHttpClient to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned HttpClient

Returns:

The conversion result.

toBlockingClient

public static BlockingHttpClient toBlockingClient(StreamingHttpClient original,
                                                  HttpExecutionStrategyInfluencer influencer)

Convert from StreamingHttpClient to BlockingHttpClient.

Parameters:

original - StreamingHttpClient to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned BlockingHttpClient

Returns:

The conversion result.

toBlockingStreamingClient

public static BlockingStreamingHttpClient toBlockingStreamingClient(StreamingHttpClient original,
                                                                    HttpExecutionStrategyInfluencer influencer)

Convert from StreamingHttpClient to BlockingStreamingHttpClient.

Parameters:

original - StreamingHttpClient to convert.

influencer - HttpExecutionStrategyInfluencer to use to derive the strategy of the returned BlockingStreamingHttpClient

Returns:

The conversion result.

toStreamingHttpService

public static HttpApiConversions.ServiceAdapterHolder toStreamingHttpService(HttpService service,
                                                                             HttpExecutionStrategyInfluencer influencer)

Convert from a HttpService to a StreamingHttpService.

Parameters:

service - The HttpService to convert.

influencer - HttpExecutionStrategyInfluencer to influence the strategy for invoking the resulting StreamingHttpService.

Returns:

HttpApiConversions.ServiceAdapterHolder containing the service adapted to the streaming programming model.

toStreamingHttpService

public static HttpApiConversions.ServiceAdapterHolder toStreamingHttpService(BlockingStreamingHttpService service,
                                                                             HttpExecutionStrategyInfluencer influencer)

Convert from a BlockingStreamingHttpService to a StreamingHttpService.

Parameters:

service - The BlockingStreamingHttpService to convert.

influencer - HttpExecutionStrategyInfluencer to influence the strategy for invoking the resulting StreamingHttpService.

Returns:

HttpApiConversions.ServiceAdapterHolder containing the service adapted to the streaming programming model.

toStreamingHttpService

public static HttpApiConversions.ServiceAdapterHolder toStreamingHttpService(BlockingHttpService service,
                                                                             HttpExecutionStrategyInfluencer influencer)

Convert from a BlockingStreamingHttpService to a StreamingHttpService.

Parameters:

service - The BlockingStreamingHttpService to convert.

influencer - HttpExecutionStrategyInfluencer to influence the strategy for invoking the resulting StreamingHttpService.

Returns:

HttpApiConversions.ServiceAdapterHolder containing the service adapted to the streaming programming model.

isPayloadEmpty

public static boolean isPayloadEmpty(HttpMetaData metadata)

Checks whether a request/response payload body is empty.

Parameters:

metadata - The request/response to check.

Returns:

true is the request/response payload body is empty, false otherwise.

isSafeToAggregate

public static boolean isSafeToAggregate(HttpMetaData metadata)

Checks whether a request/response payload is safe to aggregate, which may allow for writing a `content-length` header.

Parameters:

metadata - The request/response to check.

Returns:

true is the request/response payload is safe to aggregate, false otherwise.

mayHaveTrailers

public static boolean mayHaveTrailers(HttpMetaData metadata)

Checks whether a request/response payload may have trailers.

Parameters:

metadata - The request/response to check.

Returns:

true is the request/response payload may have trailers, false otherwise.

toBlockingHttpService

public static BlockingHttpService toBlockingHttpService(StreamingHttpService service)

Convert from a StreamingHttpService to a BlockingHttpService.

Parameters:

service - The StreamingHttpService to convert.

Returns:

The conversion result.

toHttpService

public static HttpService toHttpService(StreamingHttpService service)

Convert from a StreamingHttpService to a HttpService.

Parameters:

service - The StreamingHttpService to convert.

Returns:

The conversion result.

toBlockingStreamingHttpService

public static BlockingStreamingHttpService toBlockingStreamingHttpService(StreamingHttpService service)

Convert from a StreamingHttpService to a BlockingStreamingHttpService.

Parameters:

service - The StreamingHttpService to convert.

Returns:

The conversion result.