io.lettuce.core.failover.api

Class MultiDbConnectionFuture<C extends BaseRedisMultiDbConnection>

java.lang.Object

io.lettuce.core.BaseConnectionFuture<C>

io.lettuce.core.failover.api.MultiDbConnectionFuture<C>

Type Parameters:

C - Connection type

All Implemented Interfaces:

CompletionStage<C>, Future<C>

@Experimental
public class MultiDbConnectionFuture<C extends BaseRedisMultiDbConnection>
extends BaseConnectionFuture<C>

A MultiDbConnectionFuture represents the result of an asynchronous multi-database connection initialization.

This future wrapper delegates all method calls to the underlying CompletableFuture.

Since:

7.4

Author:

Ali Takavci

Constructor Summary

Constructors

Constructor and Description
MultiDbConnectionFuture(CompletableFuture<C> delegate) Create a new MultiDbConnectionFuture wrapping the given delegate future.

Method Summary

Modifier and Type	Method and Description
static <C extends BaseRedisMultiDbConnection> MultiDbConnectionFuture<C>	from(CompletableFuture<C> future) Create a MultiDbConnectionFuture from a CompletableFuture.
protected <U> CompletionStage<U>	wrap(CompletableFuture<U> future) Subclasses must implement this to wrap a new CompletableFuture in the appropriate subclass type.

Methods inherited from class io.lettuce.core.BaseConnectionFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, exceptionally, get, get, handle, handleAsync, handleAsync, isCancelled, isDone, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiDbConnectionFuture

public MultiDbConnectionFuture(CompletableFuture<C> delegate)

Create a new MultiDbConnectionFuture wrapping the given delegate future.

Parameters:

delegate - the underlying CompletableFuture

Method Detail

from

public static <C extends BaseRedisMultiDbConnection> MultiDbConnectionFuture<C> from(CompletableFuture<C> future)

Create a MultiDbConnectionFuture from a CompletableFuture.

Type Parameters:

C - Connection type

Parameters:

future - the CompletableFuture to wrap

Returns:

the wrapped future

wrap

protected <U> CompletionStage<U> wrap(CompletableFuture<U> future)

Description copied from class: BaseConnectionFuture

Subclasses must implement this to wrap a new CompletableFuture in the appropriate subclass type.

Specified by:

wrap in class BaseConnectionFuture<C extends BaseRedisMultiDbConnection>

Type Parameters:

U - the new type

Parameters:

future - the future to wrap

Returns:

the wrapped future