Package org.springframework.kafka.requestreply

Class 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>>
    A CompletableFuture version.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

        java.util.concurrent.CompletableFuture.AsynchronousCompletionTask

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean cancel​(boolean mayInterruptIfRunning)  
      java.util.concurrent.CompletableFuture<SendResult<K,​V>> getSendFuture()
      Return the send future as a CompletableFuture.

      • 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

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • getSendFuture

        public java.util.concurrent.CompletableFuture<SendResult<K,​V>> getSendFuture()
        Return the send future as a CompletableFuture.
        Returns:
        the send future.
        Since:
        2.9

      • cancel

        public boolean cancel​(boolean mayInterruptIfRunning)
        Specified by:
        cancel in interface java.util.concurrent.Future<org.apache.kafka.clients.consumer.ConsumerRecord<K,​R>>
        Overrides:
        cancel in class java.util.concurrent.CompletableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,​R>>