Class RequestReplyFuture.Completable
- java.lang.Object
-
- java.util.concurrent.CompletableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
-
- org.springframework.kafka.requestreply.RequestReplyFuture.Completable
-
- All Implemented Interfaces:
java.util.concurrent.CompletionStage<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>,java.util.concurrent.Future<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
- Enclosing class:
- RequestReplyFuture<K,V,R>
public class RequestReplyFuture.Completable extends java.util.concurrent.CompletableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>ACompletableFutureversion.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancancel(boolean mayInterruptIfRunning)java.util.concurrent.CompletableFuture<SendResult<K,V>>getSendFuture()Return the send future as aCompletableFuture.-
Methods inherited from class java.util.concurrent.CompletableFuture
acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, 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
-
-
-
-
Method Detail
-
getSendFuture
public java.util.concurrent.CompletableFuture<SendResult<K,V>> getSendFuture()
Return the send future as aCompletableFuture.- Returns:
- the send future.
- Since:
- 2.9
-
cancel
public boolean cancel(boolean mayInterruptIfRunning)
-
-