io.servicetalk.http.api

Class DelegatingHttpExecutionStrategy

java.lang.Object

io.servicetalk.http.api.DelegatingHttpExecutionStrategy

All Implemented Interfaces:

HttpExecutionStrategy, ExecutionStrategy

public class DelegatingHttpExecutionStrategy
extends java.lang.Object
implements HttpExecutionStrategy

An HttpExecutionStrategy that delegates all method calls to another HttpExecutionStrategy.

Constructor Summary

Constructors

Constructor and Description
DelegatingHttpExecutionStrategy(HttpExecutionStrategy delegate) Create a new instance.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
Executor	executor() Returns the Executor, if any for this ExecutionStrategy.
int	hashCode()
<FS> Single<StreamingHttpResponse>	invokeClient(Executor fallback, Publisher<java.lang.Object> flattenedRequest, FS flushStrategy, ClientInvoker<FS> client) Invokes the passed Function and applies the necessary offloading of request and response for a client.
<T> Single<T>	invokeService(Executor fallback, java.util.function.Function<Executor,T> service) Invokes a service represented by the passed Function.
Publisher<java.lang.Object>	invokeService(Executor fallback, StreamingHttpRequest request, java.util.function.Function<StreamingHttpRequest,Publisher<java.lang.Object>> service, java.util.function.BiFunction<java.lang.Throwable,Executor,Publisher<java.lang.Object>> errorHandler) Invokes the passed Function and applies the necessary offloading of request and response for a server.
boolean	isDataReceiveOffloaded() Returns true if data receive offloading is enabled for this ExecutionStrategy.
boolean	isMetadataReceiveOffloaded() Returns true if metadata receive offloading is enabled for this ExecutionStrategy.
boolean	isSendOffloaded() Returns true if send offloading is enabled for this ExecutionStrategy.
HttpExecutionStrategy	merge(HttpExecutionStrategy other) Merges the passed HttpExecutionStrategy with this HttpExecutionStrategy and return the merged result.
<T> Publisher<T>	offloadReceive(Executor fallback, Publisher<T> original) Offloads the original Publisher for receiving data from the transport.
<T> Single<T>	offloadReceive(Executor fallback, Single<T> original) Offloads the original Single for receiving data from the transport.
<T> Publisher<T>	offloadSend(Executor fallback, Publisher<T> original) Offloads the original Publisher for sending data on the transport.
<T> Single<T>	offloadSend(Executor fallback, Single<T> original) Offloads the original Single for sending data on the transport.
StreamingHttpService	offloadService(Executor fallback, StreamingHttpService handler) Wraps the passed StreamingHttpService to apply this HttpExecutionStrategy.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingHttpExecutionStrategy

public DelegatingHttpExecutionStrategy(HttpExecutionStrategy delegate)

Create a new instance.

Parameters:

delegate - HttpExecutionStrategy to which all method calls will be delegated.

Method Detail

invokeClient

public <FS> Single<StreamingHttpResponse> invokeClient(Executor fallback,
                                                       Publisher<java.lang.Object> flattenedRequest,
                                                       FS flushStrategy,
                                                       ClientInvoker<FS> client)

Description copied from interface: HttpExecutionStrategy

Invokes the passed Function and applies the necessary offloading of request and response for a client.

Specified by:

invokeClient in interface HttpExecutionStrategy

Type Parameters:

FS - The FlushStrategy type to use.

Parameters:

fallback - Executor to use as a fallback if this HttpExecutionStrategy does not define an Executor.

flattenedRequest - A flattened Publisher containing all data constituting an HTTP request.

flushStrategy - The FlushStrategy to use.

client - A BiFunction that given flattened stream of HttpRequestMetaData, payload and trailers, for the passed StreamingHttpRequest returns a Single.

Returns:

Single which is offloaded as required.

invokeService

public Publisher<java.lang.Object> invokeService(Executor fallback,
                                                 StreamingHttpRequest request,
                                                 java.util.function.Function<StreamingHttpRequest,Publisher<java.lang.Object>> service,
                                                 java.util.function.BiFunction<java.lang.Throwable,Executor,Publisher<java.lang.Object>> errorHandler)

Description copied from interface: HttpExecutionStrategy

Invokes the passed Function and applies the necessary offloading of request and response for a server.

Specified by:

invokeService in interface HttpExecutionStrategy

Parameters:

fallback - Executor to use as a fallback if this HttpExecutionStrategy does not define an Executor.

request - StreamingHttpRequest for which the offloading is to be applied.

service - A Function that executes a StreamingHttpRequest and returns a flattened Publisher containing all data constituting an HTTP response.

errorHandler - In case there is an error before calling the passed service, this BiFunction will be called to generate an error response.

Returns:

A flattened Publisher containing all data constituting an HTTP response..

invokeService

public <T> Single<T> invokeService(Executor fallback,
                                   java.util.function.Function<Executor,T> service)

Description copied from interface: HttpExecutionStrategy

Invokes a service represented by the passed Function.

This method does not apply the strategy on the object returned from the Function, if that object is an asynchronous source then the caller of this method should take care and offload that source using ExecutionStrategy.offloadSend(Executor, Single) or ExecutionStrategy.offloadSend(Executor, Publisher).

Specified by:

invokeService in interface HttpExecutionStrategy

Type Parameters:

T - Type of result of the invocation of the service.

Parameters:

fallback - Executor to use as a fallback if this HttpExecutionStrategy does not define an Executor.

service - Function representing a service.

Returns:

A Single that invokes the passed Function and returns the result asynchronously. Invocation of Function will be offloaded if configured.

offloadService

public StreamingHttpService offloadService(Executor fallback,
                                           StreamingHttpService handler)

Description copied from interface: HttpExecutionStrategy

Wraps the passed StreamingHttpService to apply this HttpExecutionStrategy.

Specified by:

offloadService in interface HttpExecutionStrategy

Parameters:

fallback - Executor to use as a fallback if this HttpExecutionStrategy does not define an Executor.

handler - StreamingHttpService to wrap.

Returns:

Wrapped StreamingHttpService.

isMetadataReceiveOffloaded

public boolean isMetadataReceiveOffloaded()

Description copied from interface: HttpExecutionStrategy

Returns true if metadata receive offloading is enabled for this ExecutionStrategy.

Specified by:

isMetadataReceiveOffloaded in interface HttpExecutionStrategy

Returns:

true if metadata receive offloading is enabled for this ExecutionStrategy.

isDataReceiveOffloaded

public boolean isDataReceiveOffloaded()

Description copied from interface: HttpExecutionStrategy

Returns true if data receive offloading is enabled for this ExecutionStrategy.

Specified by:

isDataReceiveOffloaded in interface HttpExecutionStrategy

Returns:

true if data receive offloading is enabled for this ExecutionStrategy.

isSendOffloaded

public boolean isSendOffloaded()

Description copied from interface: HttpExecutionStrategy

Returns true if send offloading is enabled for this ExecutionStrategy.

Specified by:

isSendOffloaded in interface HttpExecutionStrategy

Returns:

true if send offloading is enabled for this ExecutionStrategy.

merge

public HttpExecutionStrategy merge(HttpExecutionStrategy other)

Description copied from interface: HttpExecutionStrategy

Merges the passed HttpExecutionStrategy with this HttpExecutionStrategy and return the merged result.

Specified by:

merge in interface HttpExecutionStrategy

Parameters:

other - HttpExecutionStrategy to merge with this.

Returns:

Merged HttpExecutionStrategy.

offloadSend

public <T> Single<T> offloadSend(Executor fallback,
                                 Single<T> original)

Description copied from interface: ExecutionStrategy

Offloads the original Single for sending data on the transport.

Specified by:

offloadSend in interface ExecutionStrategy

Type Parameters:

T - Type of result of the original Single.

Parameters:

fallback - Executor to use as a fallback if this ExecutionStrategy does not define an Executor.

original - Single to offload.

Returns:

Offloaded Single.

offloadReceive

public <T> Single<T> offloadReceive(Executor fallback,
                                    Single<T> original)

Description copied from interface: ExecutionStrategy

Offloads the original Single for receiving data from the transport.

Specified by:

offloadReceive in interface ExecutionStrategy

Type Parameters:

T - Type of result of the original Single.

Parameters:

fallback - Executor to use as a fallback if this ExecutionStrategy does not define an Executor.

original - Single to offload.

Returns:

Offloaded Single.

offloadSend

public <T> Publisher<T> offloadSend(Executor fallback,
                                    Publisher<T> original)

Description copied from interface: ExecutionStrategy

Offloads the original Publisher for sending data on the transport.

Specified by:

offloadSend in interface ExecutionStrategy

Type Parameters:

T - Type of items emitted from the original Publisher.

Parameters:

fallback - Executor to use as a fallback if this ExecutionStrategy does not define an Executor.

original - Publisher to offload.

Returns:

Offloaded Publisher.

offloadReceive

public <T> Publisher<T> offloadReceive(Executor fallback,
                                       Publisher<T> original)

Description copied from interface: ExecutionStrategy

Offloads the original Publisher for receiving data from the transport.

Specified by:

offloadReceive in interface ExecutionStrategy

Type Parameters:

T - Type of items emitted from the original Publisher.

Parameters:

fallback - Executor to use as a fallback if this ExecutionStrategy does not define an Executor.

original - Publisher to offload.

Returns:

Offloaded Publisher.

executor

@Nullable
public Executor executor()

Description copied from interface: ExecutionStrategy

Returns the Executor, if any for this ExecutionStrategy.

Specified by:

executor in interface ExecutionStrategy

Returns:

Executor for this ExecutionStrategy. null if none specified.

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object