Module org.neo4j.driver

Package org.neo4j.driver.internal.util

Class Futures

java.lang.Object

org.neo4j.driver.internal.util.Futures

public final class Futures
extends Object

Method Summary

Modifier and Type	Method	Description
static CompletionException	asCompletionException(Throwable error)	Helped method to turn given exception into a CompletionException.
static <T> CompletionStage<T>	asCompletionStage(io.netty.util.concurrent.Future<T> future)
static <T> CompletionStage<T>	asCompletionStage(io.netty.util.concurrent.Future<T> future, CompletableFuture<T> result)
static <V> V	blockingGet(CompletionStage<V> stage)
static <V> V	blockingGet(CompletionStage<V> stage, Runnable interruptHandler)
static CompletionException	combineErrors(Throwable error1, Throwable error2)	Combine given errors into a single CompletionException to be rethrown from inside a CompletionStage chain.
static <T> CompletableFuture<T>	completedWithNull()
static <T> void	completeWithNullIfNoError(CompletableFuture<T> future, Throwable error)
static Throwable	completionExceptionCause(Throwable error)	Helper method to extract cause of a CompletionException.
static <T> CompletableFuture<T>	failedFuture(Throwable error)
static <T> BiConsumer<T,Throwable>	futureCompletingConsumer(CompletableFuture<T> future)
static <T> T	getNow(CompletionStage<T> stage)
static <T> T	joinNowOrElseThrow(CompletableFuture<T> future, Supplier<? extends RuntimeException> exceptionSupplier)
static <T> CompletableFuture<T>	onErrorContinue(CompletableFuture<T> future, Throwable errorRecorder, Function<Throwable,? extends CompletionStage<T>> onErrorAction)	Given a future, if the future completes successfully then return a new completed future with the completed value.

Methods inherited from class java.lang.Object

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

Method Details

completedWithNull

public static <T> CompletableFuture<T> completedWithNull()

completeWithNullIfNoError

public static <T> void completeWithNullIfNoError(CompletableFuture<T> future,
 Throwable error)

asCompletionStage

public static <T> CompletionStage<T> asCompletionStage(io.netty.util.concurrent.Future<T> future)

asCompletionStage

public static <T> CompletionStage<T> asCompletionStage(io.netty.util.concurrent.Future<T> future,
 CompletableFuture<T> result)

failedFuture

public static <T> CompletableFuture<T> failedFuture(Throwable error)

blockingGet

public static <V> V blockingGet(CompletionStage<V> stage)

blockingGet

public static <V> V blockingGet(CompletionStage<V> stage,
 Runnable interruptHandler)

getNow

public static <T> T getNow(CompletionStage<T> stage)

joinNowOrElseThrow

public static <T> T joinNowOrElseThrow(CompletableFuture<T> future,
 Supplier<? extends RuntimeException> exceptionSupplier)

completionExceptionCause

public static Throwable completionExceptionCause(Throwable error)

Helper method to extract cause of a CompletionException.

When using CompletionStage.whenComplete(BiConsumer) and CompletionStage.handle(BiFunction) propagated exceptions might get wrapped in a CompletionException.

Parameters:

error - the exception to get cause for.

Returns:

cause of the given exception if it is a CompletionException, given exception otherwise.

asCompletionException

public static CompletionException asCompletionException(Throwable error)

Helped method to turn given exception into a CompletionException.

Parameters:

error - the exception to convert.

Returns:

given exception wrapped with CompletionException if it's not one already.

combineErrors

public static CompletionException combineErrors(Throwable error1,
 Throwable error2)

Combine given errors into a single CompletionException to be rethrown from inside a CompletionStage chain.

Parameters:

error1 - the first error or null.

error2 - the second error or null.

Returns:

null if both errors are null, CompletionException otherwise.

onErrorContinue

public static <T> CompletableFuture<T> onErrorContinue(CompletableFuture<T> future,
 Throwable errorRecorder,
 Function<Throwable,? extends CompletionStage<T>> onErrorAction)

Given a future, if the future completes successfully then return a new completed future with the completed value. Otherwise if the future completes with an error, then this method first saves the error in the error recorder, and then continues with the onErrorAction.

Type Parameters:

T - type

Parameters:

future - the future.

errorRecorder - saves error if the given future completes with an error.

onErrorAction - continues the future with this action if the future completes with an error.

Returns:

a new completed future with the same completed value if the given future completes successfully, otherwise continues with the onErrorAction.

futureCompletingConsumer

public static <T> BiConsumer<T,Throwable> futureCompletingConsumer(CompletableFuture<T> future)