io.simplesource.saga.action.async

Class AsyncResult<D,K,O,R>

java.lang.Object

io.simplesource.saga.action.async.AsyncResult<D,K,O,R>

Type Parameters:

D - intermediate decoded input type

K - key for the output topic (if the result of async invocation is written to an output topic)

O - output value returned by async function

R - final result type that ends up in output topic

public final class AsyncResult<D,K,O,R>
extends Object

Represents the information required to consume the output returned by an async action, convert it to the result type R, and save it to an output topic.

Field Summary

Fields

Modifier and Type	Field and Description
java.util.function.Function<D,K>	keyMapper The Key mapper converts the decoded input type to a key for the output topic.
java.util.function.Function<O,Optional<io.simplesource.data.Result<Throwable,R>>>	outputMapper A function that takes the output of the async invocation and decodes it / converts it to the required result type.
TopicSerdes<K,R>	outputSerdes The serdes for writing the result to the output topic.

Constructor Summary

Constructors

Constructor and Description
AsyncResult()

Method Summary

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

outputMapper

public final java.util.function.Function<O,Optional<io.simplesource.data.Result<Throwable,R>>> outputMapper

A function that takes the output of the async invocation and decodes it / converts it to the required result type.

For example, the async function may be a call to a web service that returns a Json payload. This function is then be used to convert the Json to the desired result type R.

keyMapper

public final java.util.function.Function<D,K> keyMapper

The Key mapper converts the decoded input type to a key for the output topic.

outputSerdes

public final TopicSerdes<K,R> outputSerdes

The serdes for writing the result to the output topic.

Constructor Detail

AsyncResult

public AsyncResult()