Package org.redisson.api

Interface RFuture<V>

Type Parameters:

V - type of value

All Superinterfaces:

CompletionStage<V>, Future<V>

All Known Subinterfaces:

RExecutorBatchFuture, RExecutorFuture<V>, RPromise<T>, RScheduledFuture<V>

All Known Implementing Classes:

CompletableFutureWrapper, RedissonExecutorBatchFuture, RedissonExecutorFuture, RedissonPromise, RedissonScheduledFuture

public interface RFuture<V>
extends Future<V>, CompletionStage<V>

Represents the result of an asynchronous computation

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
RFuture<V>	await()	Deprecated.
boolean	await(long timeoutMillis)	Deprecated.
boolean	await(long timeout, TimeUnit unit)	Deprecated.
RFuture<V>	awaitUninterruptibly()	Deprecated.
boolean	awaitUninterruptibly(long timeoutMillis)	Deprecated.
boolean	awaitUninterruptibly(long timeout, TimeUnit unit)	Deprecated.
Throwable	cause()	Returns the cause of the failed I/O operation if the I/O operation has failed.
V	getNow()	Return the result without blocking.
boolean	isSuccess()	Returns true if and only if the I/O operation was completed successfully.
V	join()	Deprecated.
void	onComplete(BiConsumer<? super V,? super Throwable> action)	Deprecated.
RFuture<V>	sync()	Deprecated.
RFuture<V>	syncUninterruptibly()	Deprecated.

Methods inherited from interface java.util.concurrent.CompletionStage

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, exceptionally, handle, handleAsync, handleAsync, 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 interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Method Detail

isSuccess

boolean isSuccess()

Returns true if and only if the I/O operation was completed successfully.

Returns:

true if future was completed successfully

cause

Throwable cause()

Returns the cause of the failed I/O operation if the I/O operation has failed.

Returns:

the cause of the failure. null if succeeded or this future is not completed yet.

getNow

V getNow()

Return the result without blocking. If the future is not done yet this will return null. As it is possible that a null value is used to mark the future as successful you also need to check if the future is really done with Future.isDone() and not relay on the returned null value.

Returns:

object

join

@Deprecated
V join()

Deprecated.

Use toCompletableFuture().join() method instead

Returns:

the result value

await

@Deprecated
boolean await(long timeout,
              TimeUnit unit)
       throws InterruptedException

Deprecated.

Use snippet below instead.

                 try {
                     toCompletableFuture().get();
                 } catch (Exception e) {
                     // skip
                 }
 

Parameters:

timeout - - wait timeout

unit - - time unit

Returns:

true if and only if the future was completed within the specified time limit

Throws:

InterruptedException - if the current thread was interrupted

await

@Deprecated
boolean await(long timeoutMillis)
       throws InterruptedException

Deprecated.

Use snippet below instead.

                 try {
                     toCompletableFuture().get();
                 } catch (Exception e) {
                     // skip
                 }
 

Parameters:

timeoutMillis - - timeout value

Returns:

true if and only if the future was completed within the specified time limit

Throws:

InterruptedException - if the current thread was interrupted

sync

@Deprecated
RFuture<V> sync()
         throws InterruptedException

Deprecated.

Use toCompletableFuture().get() method instead

Returns:

Future object

Throws:

InterruptedException - if the current thread was interrupted

syncUninterruptibly

@Deprecated
RFuture<V> syncUninterruptibly()

Deprecated.

Use toCompletableFuture().join() method instead

Returns:

Future object

await

@Deprecated
RFuture<V> await()
          throws InterruptedException

Deprecated.

Use snippet below instead.

                 try {
                     toCompletableFuture().get();
                 } catch (Exception e) {
                     // skip
                 }
 

Returns:

Future object

Throws:

InterruptedException - if the current thread was interrupted

awaitUninterruptibly

@Deprecated
RFuture<V> awaitUninterruptibly()

Deprecated.

Use snippet below instead.

             try {
                 rFuture.toCompletableFuture().join();
             } catch (Exception e) {
                 // skip
             }
 

Returns:

Future object

awaitUninterruptibly

@Deprecated
boolean awaitUninterruptibly(long timeout,
                             TimeUnit unit)

Deprecated.

Use snippet below instead.

                 try {
                     toCompletableFuture().get();
                 } catch (Exception e) {
                     // skip
                 }
 

Parameters:

timeout - - timeout value

unit - - timeout unit value

Returns:

true if and only if the future was completed within the specified time limit

awaitUninterruptibly

@Deprecated
boolean awaitUninterruptibly(long timeoutMillis)

Deprecated.

Use snippet below instead.

                 try {
                     toCompletableFuture().get();
                 } catch (Exception e) {
                     // skip
                 }
 

Parameters:

timeoutMillis - - timeout value

Returns:

true if and only if the future was completed within the specified time limit

onComplete

@Deprecated
void onComplete(BiConsumer<? super V,? super Throwable> action)

Deprecated.

Use whenComplete() method instead

Parameters:

action - - callback