Package org.consensusj.jsonrpc

Interface AsyncSupport.TransientErrorFilter

Enclosing interface:

AsyncSupport

public static interface AsyncSupport.TransientErrorFilter

Error filter for resilient polling. Uses a Predicate to specify what to ignore and a Consumer to log what is ignored.

Method Summary

Modifier and Type	Method	Description
default <T> CompletableFuture<Optional<T>>	handle(T result, Throwable t)	Handler to transpose to a "future maybe".
boolean	isTransient(Throwable t)
void	log(Throwable t)
static AsyncSupport.TransientErrorFilter	none()
static AsyncSupport.TransientErrorFilter	of(Predicate<Throwable> filter, Consumer<Throwable> logger)

Method Details

of

static AsyncSupport.TransientErrorFilter of(Predicate<Throwable> filter,
 Consumer<Throwable> logger)

none

static AsyncSupport.TransientErrorFilter none()

handle

default <T> CompletableFuture<Optional<T>> handle(T result,
 Throwable t)

Handler to transpose to a "future maybe". Use with CompletableFuture.handle(BiFunction) followed by .thenCompose(Function.identity()) (or if JDK 12+ CompletableFuture#exceptionallyCompose(Function)) to swallow transient errors.

Type Parameters:

T - The desired return type

Parameters:

result - T

t - An error, possibly transient

Returns:

A completable future of future maybe

isTransient

boolean isTransient(Throwable t)

log

void log(Throwable t)