io.servicetalk.transport.api

Interface ExecutionStrategy

All Known Subinterfaces:

GrpcExecutionStrategy, HttpExecutionStrategy

public interface ExecutionStrategy

An execution strategy for all transports.

Method Summary

Modifier and Type	Method and Description
Executor	executor() Returns the Executor, if any for this ExecutionStrategy.
<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.

Method Detail

offloadSend

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

Offloads the original Single for sending data on the transport.

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

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

Offloads the original Single for receiving data from the transport.

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

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

Offloads the original Publisher for sending data on the transport.

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

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

Offloads the original Publisher for receiving data from the transport.

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
Executor executor()

Returns the Executor, if any for this ExecutionStrategy.

Returns:

Executor for this ExecutionStrategy. null if none specified.