Package | Description |
---|---|
io.simplesource.api | |
io.simplesource.data | |
io.simplesource.kafka.testutils |
Modifier and Type | Method and Description |
---|---|
default FutureResult<CommandError,Sequence> |
CommandAPI.publishAndQueryCommand(CommandAPI.Request<K,C> commandRequest,
java.time.Duration timeout)
Chain together publishing a command then query the result.
|
FutureResult<CommandError,CommandId> |
CommandAPI.publishCommand(CommandAPI.Request<K,C> request)
Submit the given command ready for processing.
|
FutureResult<CommandError,Sequence> |
CommandAPI.queryCommandResult(CommandId commandId,
java.time.Duration timeout)
Get the result of the execution of the command identified by the provided UUID.
|
Modifier and Type | Method and Description |
---|---|
<F> FutureResult<F,T> |
FutureResult.errorMap(java.util.function.Function<E,F> f) |
static <E,T> FutureResult<E,T> |
FutureResult.fail(E error,
E... errors) |
static <E,T> FutureResult<E,T> |
FutureResult.fail(NonEmptyList<E> errors) |
<R> FutureResult<E,R> |
FutureResult.flatMap(java.util.function.Function<T,FutureResult<E,R>> f) |
<R> FutureResult<E,R> |
FutureResult.map(java.util.function.Function<T,R> f) |
static <E,T> FutureResult<E,T> |
FutureResult.of(T t) |
static <E,T> FutureResult<E,T> |
FutureResult.ofCompletableFuture(CompletableFuture<Result<E,T>> run) |
static <E,T> FutureResult<E,T> |
FutureResult.ofFuture(Future<T> run,
java.util.function.Function<Exception,E> f) |
static <E,T> FutureResult<E,T> |
FutureResult.ofFutureResult(Future<Result<E,T>> future,
java.util.function.Function<Exception,E> f) |
static <E,T> FutureResult<E,T> |
FutureResult.ofResult(Result<E,T> result) |
static <E,T> FutureResult<E,T> |
FutureResult.ofSupplier(java.util.function.Supplier<Result<E,T>> supplier) |
Modifier and Type | Method and Description |
---|---|
<R> FutureResult<E,R> |
FutureResult.flatMap(java.util.function.Function<T,FutureResult<E,R>> f) |
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,CommandId> |
AggregateTestDriver.publishCommand(CommandAPI.Request<K,C> request) |
FutureResult<CommandError,Sequence> |
AggregateTestDriver.queryCommandResult(CommandId commandId,
java.time.Duration timeout) |
Copyright © 2019. All rights reserved.