Package org.jgroups.protocols
Class COUNTER.RequestCompletableFuture<T>
- java.lang.Object
-
- java.util.concurrent.CompletableFuture<COUNTER.ResponseData<T>>
-
- org.jgroups.protocols.COUNTER.RequestCompletableFuture<T>
-
- All Implemented Interfaces:
java.util.concurrent.CompletionStage<COUNTER.ResponseData<T>>,java.util.concurrent.Future<COUNTER.ResponseData<T>>
- Enclosing class:
- COUNTER
private static class COUNTER.RequestCompletableFuture<T> extends java.util.concurrent.CompletableFuture<COUNTER.ResponseData<T>>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) COUNTER.Requestrequest
-
Constructor Summary
Constructors Modifier Constructor Description privateRequestCompletableFuture(COUNTER.Request request)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) COUNTER.RequestgetRequest()(package private) voidrequestCompleted(long value, long version, T returnValue)(package private) voidrequestFailed(java.lang.String errorMessage)-
Methods inherited from class java.util.concurrent.CompletableFuture
acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync
-
-
-
-
Field Detail
-
request
final COUNTER.Request request
-
-
Constructor Detail
-
RequestCompletableFuture
private RequestCompletableFuture(COUNTER.Request request)
-
-
Method Detail
-
getRequest
COUNTER.Request getRequest()
-
requestCompleted
void requestCompleted(long value, long version, T returnValue)
-
requestFailed
void requestFailed(java.lang.String errorMessage)
-
-