Module org.neo4j.bolt.connection.routed

Package org.neo4j.bolt.connection.routed.impl.util

Class FutureUtil

java.lang.Object

org.neo4j.bolt.connection.routed.impl.util.FutureUtil

public class FutureUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
FutureUtil()

Method Summary

Modifier and Type	Method	Description
static void	addSuppressed(Throwable mainError, Throwable error)
static CompletionException	asCompletionException(Throwable error)
static CompletionException	combineErrors(Throwable error1, Throwable error2)
static Throwable	completionExceptionCause(Throwable error)
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)

Methods inherited from class java.lang.Object

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

Constructor Details

FutureUtil

public FutureUtil()

Method Details

asCompletionException

public static CompletionException asCompletionException(Throwable error)

completionExceptionCause

public static Throwable completionExceptionCause(Throwable error)

onErrorContinue

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

combineErrors

public static CompletionException combineErrors(Throwable error1,
 Throwable error2)

addSuppressed

public static void addSuppressed(Throwable mainError,
 Throwable error)

joinNowOrElseThrow

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