org.mule.runtime.core.api.rx

Class Exceptions

java.lang.Object

org.mule.runtime.core.api.rx.Exceptions

public class Exceptions
extends Object

Utilities for working with checked exceptions with project reactor.

Method Summary

Modifier and Type	Method and Description
static <T,U> BiConsumer<T,U>	checkedConsumer(CheckedBiConsumer<T,U> checkedBiConsumer) Adapt a CheckedBiConsumer to a BiConsumer propagating any exceptions thrown by the CheckedBiConsumer using Exceptions.propagate(Throwable).
static <T> Consumer<T>	checkedConsumer(CheckedConsumer<T> checkedConsumer) Adapt a CheckedConsumer to a Consumer propagating any exceptions thrown by the CheckedConsumer using Exceptions.propagate(Throwable).
static <T,U,R> BiFunction<T,U,R>	checkedFunction(CheckedBiFunction<T,U,R> checkedBiFunction) Adapt a CheckedBiFunction to a BiFunction propagating any exceptions thrown by the CheckedBiFunction using Exceptions.propagate(Throwable).
static <T,R> Function<T,R>	checkedFunction(CheckedFunction<T,R> checkedFunction) Adapt a CheckedFunction to a Function propagating any exceptions thrown by the CheckedFunction using Exceptions.propagate(Throwable).
static <T,U> BiPredicate<T,U>	checkedPredicate(CheckedBiPredicate<T,U> checkedBiPredicate) Adapt a CheckedBiPredicate to a BiPredicate propagating any exceptions thrown by the CheckedBiPredicate using Exceptions.propagate(Throwable).
static <T> Predicate<T>	checkedPredicate(CheckedPredicate<T> checkedPredicate) Adapt a CheckedPredicate to a Predicate propagating any exceptions thrown by the CheckedPredicate using Exceptions.propagate(Throwable).
static RuntimeException	propagateWrappingFatal(Throwable t) Propagate an exception through streams even if it's considered fatal by Reactor.
static MuleException	rxExceptionToMuleException(Throwable throwable) Unwrap reactive exception and rethrow instances MuleException or RuntimeException.
static Throwable	unwrap(Throwable throwable) Unwrap a particular Throwable.
static Throwable	wrapFatal(Throwable t) Wrap an exception with MuleFatalException so that Reactor can handle it safely instead of always bubbling it up.

Methods inherited from class java.lang.Object

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

Method Detail

checkedConsumer

public static <T> Consumer<T> checkedConsumer(CheckedConsumer<T> checkedConsumer)

Adapt a CheckedConsumer to a Consumer propagating any exceptions thrown by the CheckedConsumer using Exceptions.propagate(Throwable). Useful when using existing methods which throw checked exceptions to avoid try/catch blocks and improve readability. flux.subscribe(Exceptions.checked(v -> checkedMethod(v)

Type Parameters:

T - the type of the input to the operation

Parameters:

checkedConsumer - the consumer that throws a checked exception

Returns:

consumer that adapts CheckedConsumer and Exceptions.propagate(Throwable)'s checked exceptions

See Also:

Exceptions.propagate(Throwable)

checkedConsumer

public static <T,U> BiConsumer<T,U> checkedConsumer(CheckedBiConsumer<T,U> checkedBiConsumer)

Adapt a CheckedBiConsumer to a BiConsumer propagating any exceptions thrown by the CheckedBiConsumer using Exceptions.propagate(Throwable). Useful when using existing methods which throw checked exceptions to avoid try/catch blocks and improve readability.

Type Parameters:

T - the type of the first argument to the operation

U - the type of the second argument to the operation

Parameters:

checkedBiConsumer - the biconsumer that throws a chedked exception

Returns:

biconsumer that adapts CheckedBiConsumer and Exceptions.propagate(Throwable)'s checked exceptions

See Also:

Exceptions.propagate(Throwable)

checkedFunction

public static <T,R> Function<T,R> checkedFunction(CheckedFunction<T,R> checkedFunction)

Adapt a CheckedFunction to a Function propagating any exceptions thrown by the CheckedFunction using Exceptions.propagate(Throwable). Useful when using existing methods which throw checked exceptions to avoid try/catch blocks and improve readability. flux.map(Exceptions.checked(v -> checkedMethod(v)).subscribe(Subscribers.unbounded())

Type Parameters:

T - the type of the input to the function

R - the type of the result of the function

Parameters:

checkedFunction - the function that throws a checked exception

Returns:

function that adapts CheckedFunction and Exceptions.propagate(Throwable)'s checked exceptions

See Also:

Exceptions.propagate(Throwable)

checkedFunction

public static <T,U,R> BiFunction<T,U,R> checkedFunction(CheckedBiFunction<T,U,R> checkedBiFunction)

Adapt a CheckedBiFunction to a BiFunction propagating any exceptions thrown by the CheckedBiFunction using Exceptions.propagate(Throwable). Useful when using existing methods which throw checked exceptions to avoid try/catch blocks and improve readability.

Type Parameters:

T - the type of the first argument to the function

U - the type of the second argument to the function

R - the type of the result of the function

Parameters:

checkedBiFunction - the bifunction that throws a checked exception

Returns:

bifunction that adapts CheckedBiFunction and Exceptions.propagate(Throwable)'s checked exceptions

See Also:

Exceptions.propagate(Throwable)

checkedPredicate

public static <T> Predicate<T> checkedPredicate(CheckedPredicate<T> checkedPredicate)

Adapt a CheckedPredicate to a Predicate propagating any exceptions thrown by the CheckedPredicate using Exceptions.propagate(Throwable). Useful when using existing methods which throw checked exceptions to avoid try/catch blocks and improve readability. flux.filter(Exceptions.checked(v -> checkedMethod(v)).subscribe(Subscribers.unbounded())

Type Parameters:

T - the type of the input to the predicate

Parameters:

checkedPredicate - the predicate that throws a checked exception

Returns:

predicate that adapts CheckedPredicate and Exceptions.propagate(Throwable)'s checked exceptions

See Also:

Exceptions.propagate(Throwable)

checkedPredicate

public static <T,U> BiPredicate<T,U> checkedPredicate(CheckedBiPredicate<T,U> checkedBiPredicate)

Adapt a CheckedBiPredicate to a BiPredicate propagating any exceptions thrown by the CheckedBiPredicate using Exceptions.propagate(Throwable). Useful when using existing methods which throw checked exceptions to avoid try/catch blocks and improve readability.

Type Parameters:

T - the type of the first argument to the predicate

U - the type of the second argument the predicate

Parameters:

checkedBiPredicate - the bipredicate that throws a checked exception

Returns:

bipredicate that adapts CheckedBiPredicate and Exceptions.propagate(Throwable)'s checked exceptions

See Also:

Exceptions.propagate(Throwable)

rxExceptionToMuleException

public static MuleException rxExceptionToMuleException(Throwable throwable)
                                                throws MuleException

Unwrap reactive exception and rethrow instances MuleException or RuntimeException. Other exception types are wrapped in a instance of DefaultMuleException.

Parameters:

throwable -

Returns:

Throws:

MuleException

unwrap

public static Throwable unwrap(Throwable throwable)

Unwrap a particular Throwable.

Parameters:

throwable - the exception to wrap

Returns:

the unwrapped exception

propagateWrappingFatal

public static RuntimeException propagateWrappingFatal(Throwable t)

Propagate an exception through streams even if it's considered fatal by Reactor.

Parameters:

t - throwable.

Returns:

exception wrapped by Reactor, after possibly wrapping with MuleFatalException.

wrapFatal

public static Throwable wrapFatal(Throwable t)

Wrap an exception with MuleFatalException so that Reactor can handle it safely instead of always bubbling it up.

Parameters:

t - throwable.

Returns:

possibly wrapped exception.