Package org.elasticsearch.common.concurrent

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 the CompletableFuture for the concurrency logic. However, it does not accept Throwable as an exceptional result. This allows attaching listeners that only handle Exception.

  • 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()  

    Methods inherited from class java.lang.Object

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