Exceptions (Reactor Core 3.0.6.RELEASE)

java.lang.Object
- reactor.core.Exceptions

```
public abstract class Exceptions
extends Object
```
Global Reactor Core Exception handling and utils to operate on.

Author:

Stephane Maldini

See Also:

Reactive-Streams-Commons

Field Summary

Fields
Modifier and Type	Field and Description
`static boolean`	`CANCEL_STACKTRACE` Deprecated. Cancel stacktrace is always turned on given the exceptional frequency and the critical info it can provide
`static Throwable`	`TERMINATED` A singleton instance of a Throwable indicating a terminal state for exceptions, don't leak this!

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static <T> boolean`	`addThrowable(AtomicReferenceFieldUpdater<T,Throwable> field, T instance, Throwable exception)`
`static NullPointerException`	`argumentIsNullException()`
`static RuntimeException`	`bubble(Throwable t)` Return an unchecked `RuntimeException` to be thrown that will bubble upstream.
`static IllegalStateException`	`duplicateOnSubscribeException()`
`static UnsupportedOperationException`	`errorCallbackNotImplemented(Throwable cause)` Return an `UnsupportedOperationException`
`static RuntimeException`	`failWithCancel()` An exception that is propagated upward and considered as "fatal" as per Reactive Stream limited list of exceptions allowed to bubble.
`static IllegalStateException`	`failWithOverflow()` Return an `IllegalStateException` indicating the receiver is overrun by more signals than expected in case of a bounded queue, or more generally that data couldn't be emitted due to a lack of request
`static IllegalStateException`	`failWithOverflow(String message)` Return an `IllegalStateException` indicating the receiver is overrun by more signals than expected in case of a bounded queue or more generally that data couldn't be emitted due to a lack of request
`static boolean`	`isBubbling(Throwable t)` Check if the given error is a bubbled wrapped exception.
`static boolean`	`isCancel(Throwable t)` Check if the given error is a cancel signal.
`static boolean`	`isErrorCallbackNotImplemented(Throwable cause)` Return an `UnsupportedOperationException`
`static boolean`	`isOverflow(Throwable t)`
`static IllegalArgumentException`	`nullOrNegativeRequestException(long elements)`
`static RuntimeException`	`propagate(Throwable t)` Return an unchecked `RuntimeException` to be thrown that will be propagated downstream through `Subscriber.onError(Throwable)`.
`static <T> Throwable`	`terminate(AtomicReferenceFieldUpdater<T,Throwable> field, T instance)` Atomic utility to safely mark a volatile throwable reference with a terminal marker.
`static void`	`throwIfFatal(Throwable t)` Throws a particular `Throwable` only if it belongs to a set of "fatal" error varieties.
`static void`	`throwIfJvmFatal(Throwable t)` Throws a particular `Throwable` only if it belongs to a set of "fatal" error varieties native to the JVM.
`static Throwable`	`unwrap(Throwable t)` Unwrap a particular `Throwable` only if it is a wrapped exception via `bubble(java.lang.Throwable)` or `propagate(java.lang.Throwable)`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - CANCEL_STACKTRACE
```
@Deprecated
public static final boolean CANCEL_STACKTRACE
```
    Deprecated. Cancel stacktrace is always turned on given the exceptional frequency and the critical info it can provide
    
    See Also:
    
    Constant Field Values
  - TERMINATED
```
public static final Throwable TERMINATED
```
    A singleton instance of a Throwable indicating a terminal state for exceptions, don't leak this!
- Method Detail
  - addThrowable
```
public static <T> boolean addThrowable(AtomicReferenceFieldUpdater<T,Throwable> field,
                                       T instance,
                                       Throwable exception)
```
    Type Parameters:
    
    T - the parent instance type
    
    Parameters:
    
    field - the target field updater
    
    instance - the parent instance for the field
    
    exception - the Throwable to add.
    
    Returns:
    
    true if added, false if the field contained the TERMINATED instance.
  - argumentIsNullException
```
public static NullPointerException argumentIsNullException()
```
    Returns:
    
    a new NullPointerException with a cause message abiding to reactive stream specification.
  - bubble
```
public static RuntimeException bubble(Throwable t)
```
    Return an unchecked RuntimeException to be thrown that will bubble upstream.
    This method invokes throwIfFatal(Throwable).
    
    Parameters:
    
    t - the root cause
    
    Returns:
    
    an unchecked exception that should choose bubbling up over error callback path
  - duplicateOnSubscribeException
```
public static IllegalStateException duplicateOnSubscribeException()
```
    Returns:
    
    a new IllegalStateException with a cause message abiding to reactive stream specification.
  - errorCallbackNotImplemented
```
public static UnsupportedOperationException errorCallbackNotImplemented(Throwable cause)
```
    Return an UnsupportedOperationException
    
    Parameters:
    
    cause - original error not processed by a receiver.
    
    Returns:
    
    an UnsupportedOperationException
  - failWithCancel
```
public static RuntimeException failWithCancel()
```
    An exception that is propagated upward and considered as "fatal" as per Reactive Stream limited list of exceptions allowed to bubble. It is not meant to be common error resolution but might assist implementors in dealing with boundaries (queues, combinations and async).
    
    Returns:
    
    a RuntimeException that can be checked via isCancel(java.lang.Throwable)
  - failWithOverflow
```
public static IllegalStateException failWithOverflow()
```
    Return an IllegalStateException indicating the receiver is overrun by more signals than expected in case of a bounded queue, or more generally that data couldn't be emitted due to a lack of request
    
    Returns:
    
    an IllegalStateException
  - failWithOverflow
```
public static IllegalStateException failWithOverflow(String message)
```
    Return an IllegalStateException indicating the receiver is overrun by more signals than expected in case of a bounded queue or more generally that data couldn't be emitted due to a lack of request
    
    Parameters:
    
    message - the exception's message
    
    Returns:
    
    an IllegalStateException
  - isOverflow
```
public static boolean isOverflow(Throwable t)
```
    Returns:
    
    true if the given Throwable represents an overflow.
  - isBubbling
```
public static boolean isBubbling(Throwable t)
```
    Check if the given error is a bubbled wrapped exception.
    
    Parameters:
    
    t - the Throwable error to check
    
    Returns:
    
    true if given error is a a bubbled wrapped exception.
  - isCancel
```
public static boolean isCancel(Throwable t)
```
    Check if the given error is a cancel signal.
    
    Parameters:
    
    t - the Throwable error to check
    
    Returns:
    
    true if given error is a cancellation token.
  - isErrorCallbackNotImplemented
```
public static boolean isErrorCallbackNotImplemented(Throwable cause)
```
    Return an UnsupportedOperationException
    
    Parameters:
    
    cause - original error not processed by a receiver.
    
    Returns:
    
    an UnsupportedOperationException
  - nullOrNegativeRequestException
```
public static IllegalArgumentException nullOrNegativeRequestException(long elements)
```
    Parameters:
    
    elements - the invalid requested demand
    
    Returns:
    
    a new IllegalArgumentException with a cause message abiding to reactive stream specification.
  - propagate
```
public static RuntimeException propagate(Throwable t)
```
    Return an unchecked RuntimeException to be thrown that will be propagated downstream through Subscriber.onError(Throwable).
    This method invokes throwIfFatal(Throwable).
    
    Parameters:
    
    t - the root cause
    
    Returns:
    
    an unchecked exception
  - terminate
```
public static <T> Throwable terminate(AtomicReferenceFieldUpdater<T,Throwable> field,
                                      T instance)
```
    Atomic utility to safely mark a volatile throwable reference with a terminal marker.
    
    Type Parameters:
    
    T - the instance type
    
    Parameters:
    
    field - the atomic container
    
    instance - the reference instance
    
    Returns:
    
    the previously masked throwable
  - throwIfFatal
```
public static void throwIfFatal(Throwable t)
```
    Throws a particular Throwable only if it belongs to a set of "fatal" error varieties. These varieties are as follows:
    - BubblingException
    - ErrorCallbackNotImplemented
    - VirtualMachineError
    - ThreadDeath
    - LinkageError
    Parameters:
    
    t - the exception to evaluate
  - throwIfJvmFatal
```
public static void throwIfJvmFatal(Throwable t)
```
    Throws a particular Throwable only if it belongs to a set of "fatal" error varieties native to the JVM. These varieties are as follows:
    - VirtualMachineError
    - ThreadDeath
    - LinkageError
    Parameters:
    
    t - the exception to evaluate
  - unwrap
```
public static Throwable unwrap(Throwable t)
```
    Unwrap a particular Throwable only if it is a wrapped exception via bubble(java.lang.Throwable) or propagate(java.lang.Throwable).
    
    Parameters:
    
    t - the exception to wrap
    
    Returns:
    
    the unwrapped exception

Class Exceptions

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

CANCEL_STACKTRACE

TERMINATED

Method Detail

addThrowable

argumentIsNullException

bubble

duplicateOnSubscribeException

errorCallbackNotImplemented

failWithCancel

failWithOverflow

failWithOverflow

isOverflow

isBubbling

isCancel

isErrorCallbackNotImplemented

nullOrNegativeRequestException

propagate

terminate

throwIfFatal

throwIfJvmFatal

unwrap