Interface Clients

public interface Clients

Provides functionality for generated code to make both blocking and asynchronous calls without duplicating logic.

Method Summary

Modifier and Type	Method	Description
default EndpointChannel	bind(Channel channel, Endpoint endpoint)
<T> T	block(com.google.common.util.concurrent.ListenableFuture<T> future)	Similar to Futures.getUnchecked(Future), except with custom handling for conjure exceptions and cancellation on interruption.
<T> com.google.common.util.concurrent.ListenableFuture<T>	call(Channel channel, Endpoint endpoint, Request request, Deserializer<T> deserializer)	Makes a request to the specified Endpoint and deserializes the response using a provided deserializer.
<T> com.google.common.util.concurrent.ListenableFuture<T>	call(EndpointChannel channel, Request request, Deserializer<T> deserializer)	Makes a request to the specified EndpointChannel and deserializes the response using a provided deserializer.
default <T> T	callBlocking(EndpointChannel channel, Request request, Deserializer<T> deserializer)	Blocking version of call(EndpointChannel, Request, Deserializer).

Method Details

call

<T>
com.google.common.util.concurrent.ListenableFuture<T> call(EndpointChannel channel,
 Request request,
 Deserializer<T> deserializer)

Makes a request to the specified EndpointChannel and deserializes the response using a provided deserializer.

call

<T>
com.google.common.util.concurrent.ListenableFuture<T> call(Channel channel,
 Endpoint endpoint,
 Request request,
 Deserializer<T> deserializer)

Makes a request to the specified Endpoint and deserializes the response using a provided deserializer. Deprecated. prefer bind(Channel, Endpoint) as this allows pre-computing values to save CPU

callBlocking

default <T> T callBlocking(EndpointChannel channel,
 Request request,
 Deserializer<T> deserializer)

Blocking version of call(EndpointChannel, Request, Deserializer).

bind

default EndpointChannel bind(Channel channel,
 Endpoint endpoint)

block

<T> T block(com.google.common.util.concurrent.ListenableFuture<T> future)

Similar to Futures.getUnchecked(Future), except with custom handling for conjure exceptions and cancellation on interruption. Deprecated. prefer callBlocking(EndpointChannel, Request, Deserializer) as it makes the blocking explicit.