Class CompletableContext<T>
- java.lang.Object
-
- org.elasticsearch.common.concurrent.CompletableContext<T>
-
- Type Parameters:
T
- the result type
public class CompletableContext<T> extends java.lang.Object
A thread-safe completable context that allows listeners to be attached. This class relies on theCompletableFuture
for the concurrency logic. However, it does not acceptThrowable
as an exceptional result. This allows attaching listeners that only handleException
.
-
-
Constructor Summary
Constructors Constructor Description CompletableContext()
-
Method Summary
Modifier and Type Method Description void
addListener(java.util.function.BiConsumer<T,? super java.lang.Exception> listener)
boolean
complete(T value)
boolean
completeExceptionally(java.lang.Exception ex)
boolean
isCompletedExceptionally()
boolean
isDone()
-
-
-
Method Detail
-
addListener
public void addListener(java.util.function.BiConsumer<T,? super java.lang.Exception> listener)
-
isDone
public boolean isDone()
-
isCompletedExceptionally
public boolean isCompletedExceptionally()
-
completeExceptionally
public boolean completeExceptionally(java.lang.Exception ex)
-
complete
public boolean complete(T value)
-
-