Package software.amazon.awssdk.utils.async

Class StoringSubscriber.Event<T>

java.lang.Object

software.amazon.awssdk.utils.async.StoringSubscriber.Event<T>

Enclosing class:

StoringSubscriber<T>

public static final class StoringSubscriber.Event<T>
extends Object

An event stored for later retrieval by this subscriber.

Stored events are one of the follow type()s:

• VALUE - A value received by StoringSubscriber.onNext(Object), available via value().
• COMPLETE - Indicating StoringSubscriber.onComplete() was called.
• ERROR - Indicating StoringSubscriber.onError(Throwable) was called. The exception is available via runtimeError()
• EMPTY - Indicating that no events remain in the queue (but more from upstream may be given later).

Method Summary

Modifier and Type	Method	Description
RuntimeException	runtimeError()	The error stored in this ERROR type.
StoringSubscriber.EventType	type()	Retrieve the StoringSubscriber.EventType of this event.
T	value()	The value stored in this VALUE type.

Methods inherited from class java.lang.Object

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

Method Details

type

public StoringSubscriber.EventType type()

Retrieve the StoringSubscriber.EventType of this event.

value

public T value()

The value stored in this VALUE type. Null for all other event types.

runtimeError

public RuntimeException runtimeError()

The error stored in this ERROR type. Null for all other event types. If a checked exception was received via StoringSubscriber.onError(Throwable), this will return a RuntimeException with the checked exception as its cause.