Package dev.restate.client

Interface Client.AwakeableHandle

Enclosing interface:

Client

public static interface Client.AwakeableHandle

This class represents a handle to an Awakeable. It can be used to complete awakeables from the ingress

Method Summary

Modifier and Type	Method	Description
default Response<Void>	reject(String reason)	Complete with failure the Awakeable.
default Response<Void>	reject(String reason, RequestOptions options)	Same as reject(String) with options.
default CompletableFuture<Response<Void>>	rejectAsync(String reason)	Same as reject(String) but async.
CompletableFuture<Response<Void>>	rejectAsync(String reason, RequestOptions options)	Same as reject(String) but async with options.
default <T> Response<Void>	resolve(TypeTag<T> serde, @NonNull T payload)	Complete with success the Awakeable.
default <T> Response<Void>	resolve(TypeTag<T> serde, @NonNull T payload, RequestOptions options)	Same as resolve(TypeTag, Object) with options.
default <T> Response<Void>	resolve(Class<T> clazz, @NonNull T payload)	Complete with success the Awakeable.
default <T> Response<Void>	resolve(Class<T> clazz, @NonNull T payload, RequestOptions options)	Same as resolve(TypeTag, Object) with options.
default <T> CompletableFuture<Response<Void>>	resolveAsync(TypeTag<T> serde, @NonNull T payload)	Same as resolve(TypeTag, Object) but async.
<T> CompletableFuture<Response<Void>>	resolveAsync(TypeTag<T> serde, @NonNull T payload, RequestOptions options)	Same as resolve(TypeTag, Object) but async with options.
default <T> CompletableFuture<Response<Void>>	resolveAsync(Class<T> clazz, @NonNull T payload)	Same as resolve(TypeTag, Object) but async.
default <T> CompletableFuture<Response<Void>>	resolveAsync(Class<T> clazz, @NonNull T payload, RequestOptions options)	Same as resolve(Class, Object) but async with options.

Method Details

resolveAsync

<T> CompletableFuture<Response<Void>> resolveAsync(TypeTag<T> serde,
 @NonNull T payload,
 RequestOptions options)

Same as resolve(TypeTag, Object) but async with options.

resolveAsync

default <T> CompletableFuture<Response<Void>> resolveAsync(TypeTag<T> serde,
 @NonNull T payload)

Same as resolve(TypeTag, Object) but async.

resolve

default <T> Response<Void> resolve(TypeTag<T> serde,
 @NonNull T payload,
 RequestOptions options)

Same as resolve(TypeTag, Object) with options.

resolve

default <T> Response<Void> resolve(Class<T> clazz,
 @NonNull T payload)

Complete with success the Awakeable.

Parameters:

clazz - used to serialize the Awakeable result payload.

payload - the result payload. MUST NOT be null.

resolveAsync

default <T> CompletableFuture<Response<Void>> resolveAsync(Class<T> clazz,
 @NonNull T payload,
 RequestOptions options)

Same as resolve(Class, Object) but async with options.

resolveAsync

default <T> CompletableFuture<Response<Void>> resolveAsync(Class<T> clazz,
 @NonNull T payload)

Same as resolve(TypeTag, Object) but async.

resolve

default <T> Response<Void> resolve(Class<T> clazz,
 @NonNull T payload,
 RequestOptions options)

Same as resolve(TypeTag, Object) with options.

resolve

default <T> Response<Void> resolve(TypeTag<T> serde,
 @NonNull T payload)

Complete with success the Awakeable.

Parameters:

serde - used to serialize the Awakeable result payload.

payload - the result payload. MUST NOT be null.

rejectAsync

CompletableFuture<Response<Void>> rejectAsync(String reason,
 RequestOptions options)

Same as reject(String) but async with options.

rejectAsync

default CompletableFuture<Response<Void>> rejectAsync(String reason)

Same as reject(String) but async.

reject

default Response<Void> reject(String reason,
 RequestOptions options)

Same as reject(String) with options.

reject

default Response<Void> reject(String reason)

Complete with failure the Awakeable.

Parameters:

reason - the rejection reason. MUST NOT be null.