Package org.apache.bookkeeper.client

Class SyncCallbackUtils.FutureReadLastConfirmedAndEntry

java.lang.Object

java.util.concurrent.CompletableFuture<LastConfirmedAndEntry>

org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmedAndEntry

All Implemented Interfaces:

CompletionStage<LastConfirmedAndEntry>, Future<LastConfirmedAndEntry>, AsyncCallback.ReadLastConfirmedAndEntryCallback

Enclosing class:

SyncCallbackUtils

static class SyncCallbackUtils.FutureReadLastConfirmedAndEntry
extends CompletableFuture<LastConfirmedAndEntry>
implements AsyncCallback.ReadLastConfirmedAndEntryCallback

Nested Class Summary

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

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
FutureReadLastConfirmedAndEntry()

Method Summary

Modifier and Type	Method	Description
void	readLastConfirmedAndEntryComplete(int rc, long lastConfirmed, LedgerEntry entry, Object ctx)	Callback definition for bookie operation that allows reading the last add confirmed along with an entry within the last add confirmed range.

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, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, 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

Constructor Details

FutureReadLastConfirmedAndEntry

FutureReadLastConfirmedAndEntry()

Method Details

readLastConfirmedAndEntryComplete

public void readLastConfirmedAndEntryComplete(int rc,
 long lastConfirmed,
 LedgerEntry entry,
 Object ctx)

Description copied from interface: AsyncCallback.ReadLastConfirmedAndEntryCallback

Callback definition for bookie operation that allows reading the last add confirmed along with an entry within the last add confirmed range.

Specified by:

readLastConfirmedAndEntryComplete in interface AsyncCallback.ReadLastConfirmedAndEntryCallback

Parameters:

rc - Return code

lastConfirmed - The entry id of the last confirmed write or INVALID_ENTRY_ID if no entry has been confirmed

entry - The entry since the lastAddConfirmed entry that was specified when the request was initiated

ctx - context object