Package dev.restate.sdk.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 void	reject(String reason)	Complete with failure the Awakeable.
default void	reject(String reason, RequestOptions options)	Same as reject(String) with options.
default CompletableFuture<Void>	rejectAsync(String reason)	Same as reject(String) but async.
CompletableFuture<Void>	rejectAsync(String reason, RequestOptions options)	Same as reject(String) but async with options.
default <T> void	resolve(Serde<T> serde, @NonNull T payload)	Complete with success the Awakeable.
default <T> void	resolve(Serde<T> serde, @NonNull T payload, RequestOptions options)	Same as resolve(Serde, Object) with options.
default <T> CompletableFuture<Void>	resolveAsync(Serde<T> serde, @NonNull T payload)	Same as resolve(Serde, Object) but async.
<T> CompletableFuture<Void>	resolveAsync(Serde<T> serde, @NonNull T payload, RequestOptions options)	Same as resolve(Serde, Object) but async with options.

Method Details

resolveAsync

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

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

resolveAsync

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

Same as resolve(Serde, Object) but async.

resolve

default <T> void resolve(Serde<T> serde,
 @NonNull T payload,
 RequestOptions options)

Same as resolve(Serde, Object) with options.

resolve

default <T> void resolve(Serde<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<Void> rejectAsync(String reason,
 RequestOptions options)

Same as reject(String) but async with options.

rejectAsync

default CompletableFuture<Void> rejectAsync(String reason)

Same as reject(String) but async.

reject

default void reject(String reason,
 RequestOptions options)

Same as reject(String) with options.

reject

default void reject(String reason)

Complete with failure the Awakeable.

Parameters:

reason - the rejection reason. MUST NOT be null.