Package org.apache.cassandra.utils

Class Throwables

java.lang.Object

org.apache.cassandra.utils.Throwables

public final class Throwables
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Throwables.DiscreteAction<E extends Exception>
static enum	Throwables.FileOpType

Constructor Summary

Constructors

Constructor	Description
Throwables()

Method Summary

Modifier and Type	Method	Description
static boolean	anyCauseMatches(Throwable t, Predicate<Throwable> cause)
static void	assertAnyCause(Throwable err, Class<? extends Throwable> cause)
static RuntimeException	cleaned(Throwable t)	A shortcut for unchecked(unwrapped(t)).
static Throwable	close(Throwable accumulate, AutoCloseable... closeables)	See close(Throwable, Iterable)
static Throwable	close(Throwable accumulate, Iterable<? extends AutoCloseable> closeables)	Closes all the resources in the provided collections and accumulates the possible exceptions thrown when closing.
static void	closeAndAddSuppressed(Throwable t, AutoCloseable... closeables)	See closeAndAddSuppressed(Throwable, Iterable)
static void	closeAndAddSuppressed(Throwable accumulate, Iterable<AutoCloseable> closeables)	Closes all closables in the provided collections and accumulates the possible exceptions thrown when closing.
static void	closeNonNullAndAddSuppressed(Throwable t, AutoCloseable... closeables)	Do what closeAndAddSuppressed(Throwable, Iterable) does, additionally filtering out all null closables.
static Optional<IOException>	extractIOExceptionCause(Throwable t)
static <T extends Throwable> boolean	failIfCanCast(Throwable fail, Class<T> checked)
static boolean	isCausedBy(Throwable t, Predicate<Throwable> cause)
static void	maybeFail(Throwable fail)
static <T extends Throwable> void	maybeFail(Throwable fail, Class<T> checked)
static <E extends Exception> void	maybeFail(Throwables.DiscreteAction<? extends E>... actions)
static <T extends Throwable> T	merge(T existingFail, T newFail)
static void	perform(String filePath, Throwables.FileOpType opType, Throwables.DiscreteAction<? extends IOException>... actions)
static Throwable	perform(Throwable accumulate, String filePath, Throwables.FileOpType opType, Stream<Throwables.DiscreteAction<? extends IOException>> actions)
static Throwable	perform(Throwable accumulate, String filePath, Throwables.FileOpType opType, Throwables.DiscreteAction<? extends IOException>... actions)
static Throwable	perform(Throwable accumulate, Iterator<? extends Throwables.DiscreteAction<?>> actions)
static Throwable	perform(Throwable accumulate, Stream<? extends Throwables.DiscreteAction<?>> actions)
static Throwable	perform(Throwable accumulate, Throwables.DiscreteAction<?>... actions)
static <E extends Exception> void	perform(Stream<? extends Throwables.DiscreteAction<? extends E>> stream, Throwables.DiscreteAction<? extends E>... extra)
static <E extends Exception> void	perform(Stream<Throwables.DiscreteAction<? extends E>> actions)
static void	perform(File against, Throwables.FileOpType opType, Throwables.DiscreteAction<? extends IOException>... actions)
static <E extends Exception> void	perform(Throwables.DiscreteAction<? extends E>... actions)
static RuntimeException	throwAsUncheckedException(Throwable t)	throw the exception as a unchecked exception, wrapping if a checked exception, else rethroing as is.
static RuntimeException	unchecked(Throwable t)	If the provided exception is unchecked, return it directly, otherwise wrap it into a RuntimeException to make it unchecked.
static Throwable	unwrapped(Throwable t)	If the provided throwable is a "wrapping" exception (see below), return the cause of that throwable, otherwise return its argument untouched.

Methods inherited from class java.lang.Object

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

Constructor Details

Throwables

public Throwables()

Method Details

isCausedBy

public static boolean isCausedBy(Throwable t,
 Predicate<Throwable> cause)

anyCauseMatches

public static boolean anyCauseMatches(Throwable t,
 Predicate<Throwable> cause)

merge

public static <T extends Throwable> T merge(T existingFail,
 T newFail)

maybeFail

public static void maybeFail(Throwable fail)

maybeFail

public static <T extends Throwable> void maybeFail(Throwable fail,
 Class<T> checked)
                                            throws T

Throws:

T extends Throwable

failIfCanCast

public static <T extends Throwable> boolean failIfCanCast(Throwable fail,
 Class<T> checked)
                                                   throws T

Throws:

T extends Throwable

maybeFail

@SafeVarargs
public static <E extends Exception> void maybeFail(Throwables.DiscreteAction<? extends E>... actions)

perform

@SafeVarargs
public static <E extends Exception> void perform(Throwables.DiscreteAction<? extends E>... actions)
                                          throws E

Throws:

E extends Exception

perform

public static <E extends Exception> void perform(Stream<? extends Throwables.DiscreteAction<? extends E>> stream,
 Throwables.DiscreteAction<? extends E>... extra)
                                          throws E

Throws:

E extends Exception

perform

public static <E extends Exception> void perform(Stream<Throwables.DiscreteAction<? extends E>> actions)
                                          throws E

Throws:

E extends Exception

perform

public static Throwable perform(Throwable accumulate,
 Throwables.DiscreteAction<?>... actions)

perform

public static Throwable perform(Throwable accumulate,
 Stream<? extends Throwables.DiscreteAction<?>> actions)

perform

public static Throwable perform(Throwable accumulate,
 Iterator<? extends Throwables.DiscreteAction<?>> actions)

perform

@SafeVarargs
public static void perform(File against,
 Throwables.FileOpType opType,
 Throwables.DiscreteAction<? extends IOException>... actions)

perform

@SafeVarargs
public static void perform(String filePath,
 Throwables.FileOpType opType,
 Throwables.DiscreteAction<? extends IOException>... actions)

perform

@SafeVarargs
public static Throwable perform(Throwable accumulate,
 String filePath,
 Throwables.FileOpType opType,
 Throwables.DiscreteAction<? extends IOException>... actions)

perform

public static Throwable perform(Throwable accumulate,
 String filePath,
 Throwables.FileOpType opType,
 Stream<Throwables.DiscreteAction<? extends IOException>> actions)

closeAndAddSuppressed

public static void closeAndAddSuppressed(@Nonnull
 Throwable t,
 AutoCloseable... closeables)

See closeAndAddSuppressed(Throwable, Iterable)

closeNonNullAndAddSuppressed

public static void closeNonNullAndAddSuppressed(@Nonnull
 Throwable t,
 AutoCloseable... closeables)

Do what closeAndAddSuppressed(Throwable, Iterable) does, additionally filtering out all null closables.

closeAndAddSuppressed

public static void closeAndAddSuppressed(@Nonnull
 Throwable accumulate,
 Iterable<AutoCloseable> closeables)

Closes all closables in the provided collections and accumulates the possible exceptions thrown when closing.

Parameters:

accumulate - non-null exception to accumulate errors thrown when closing the provided resources

closeables - closeables to be closed

close

public static Throwable close(Throwable accumulate,
 AutoCloseable... closeables)

See close(Throwable, Iterable)

close

public static Throwable close(Throwable accumulate,
 Iterable<? extends AutoCloseable> closeables)

Closes all the resources in the provided collections and accumulates the possible exceptions thrown when closing.

Parameters:

accumulate - the initial value for the exception accumulator, can be null

closeables - closeables to be closed

Returns:

null, or the first exception thrown when closing the provided resources

extractIOExceptionCause

public static Optional<IOException> extractIOExceptionCause(Throwable t)

unwrapped

public static Throwable unwrapped(Throwable t)

If the provided throwable is a "wrapping" exception (see below), return the cause of that throwable, otherwise return its argument untouched.

We call a "wrapping" exception in the context of that method an exception whose only purpose is to wrap another exception, and currently this method recognize only 2 exception as "wrapping" ones: ExecutionException and CompletionException.

unchecked

public static RuntimeException unchecked(Throwable t)

If the provided exception is unchecked, return it directly, otherwise wrap it into a RuntimeException to make it unchecked.

throwAsUncheckedException

public static RuntimeException throwAsUncheckedException(Throwable t)

throw the exception as a unchecked exception, wrapping if a checked exception, else rethroing as is.

cleaned

public static RuntimeException cleaned(Throwable t)

A shortcut for unchecked(unwrapped(t)). This is called "cleaned" because this basically removes the annoying cruft surrounding an exception :).

assertAnyCause

public static void assertAnyCause(Throwable err,
 Class<? extends Throwable> cause)