Constructor and Description |
---|
PrimaryOwnerOnlyCollector() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<T> |
getFuture() |
void |
primaryException(Throwable throwable)
The exception results of the primary owner.
|
void |
primaryResult(T result,
boolean success)
The write operation's return value.
|
public CompletableFuture<T> getFuture()
getFuture
in interface Collector<T>
CompletableFuture
that will be completed when all the acks are received.public void primaryException(Throwable throwable)
Collector
primaryException
in interface Collector<T>
throwable
- the Throwable
throw by the primary ownerpublic void primaryResult(T result, boolean success)
Collector
primaryResult
in interface Collector<T>
result
- the operation's return valuesuccess
- true
if it was successful, false
otherwise (for conditional operations).Copyright © 2021 JBoss by Red Hat. All rights reserved.