public enum NotificationLite extends java.lang.Enum<NotificationLite>
| Modifier and Type | Method and Description |
|---|---|
static <T> boolean |
accept(java.lang.Object o,
NbpObservable.NbpSubscriber<? super T> s)
Calls the appropriate NbpSubscriber method based on the type of the notification.
|
static <T> boolean |
accept(java.lang.Object o,
org.reactivestreams.Subscriber<? super T> s)
Calls the appropriate Subscriber method based on the type of the notification.
|
static <T> boolean |
acceptFull(java.lang.Object o,
NbpObservable.NbpSubscriber<? super T> s)
Calls the appropriate NbpSubscriber method based on the type of the notification.
|
static <T> boolean |
acceptFull(java.lang.Object o,
org.reactivestreams.Subscriber<? super T> s)
Calls the appropriate Subscriber method based on the type of the notification.
|
static java.lang.Object |
complete()
Returns a complete notification.
|
static java.lang.Object |
disposable(Disposable d)
Converts a Disposable into a notification value.
|
static java.lang.Object |
error(java.lang.Throwable e)
Converts a Throwable into a notification value.
|
static Disposable |
getDisposable(java.lang.Object o) |
static java.lang.Throwable |
getError(java.lang.Object o)
Extracts the Throwable from the notification object
|
static org.reactivestreams.Subscription |
getSubscription(java.lang.Object o)
Extracts the Subscription from the notification object
|
static <T> T |
getValue(java.lang.Object o)
Extracts the value from the notification object
|
static boolean |
isComplete(java.lang.Object o)
Checks if the given object represents a complete notification.
|
static boolean |
isDisposable(java.lang.Object o) |
static boolean |
isError(java.lang.Object o)
Checks if the given object represents a error notification.
|
static boolean |
isSubscription(java.lang.Object o)
Checks if the given object represents a subscription notification.
|
static <T> java.lang.Object |
next(T value)
Converts a value into a notification value.
|
static java.lang.Object |
subscription(org.reactivestreams.Subscription s)
Converts a Subscription into a notification value.
|
static NotificationLite |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static NotificationLite[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static NotificationLite[] values()
for (NotificationLite c : NotificationLite.values()) System.out.println(c);
public static NotificationLite valueOf(java.lang.String name)
name - the name of the enum constant to be returned.java.lang.IllegalArgumentException - if this enum type has no constant with the specified namejava.lang.NullPointerException - if the argument is nullpublic static <T> java.lang.Object next(T value)
T - the actual value typevalue - the value to convertpublic static java.lang.Object complete()
public static java.lang.Object error(java.lang.Throwable e)
e - the Throwable to convertpublic static java.lang.Object subscription(org.reactivestreams.Subscription s)
s - the Subscription to convertpublic static java.lang.Object disposable(Disposable d)
d - the disposable to convertpublic static boolean isComplete(java.lang.Object o)
o - the object to checkpublic static boolean isError(java.lang.Object o)
o - the object to checkpublic static boolean isSubscription(java.lang.Object o)
o - the object to checkpublic static boolean isDisposable(java.lang.Object o)
public static <T> T getValue(java.lang.Object o)
T - the expected value type when unwrappedo - the notification objectpublic static java.lang.Throwable getError(java.lang.Object o)
o - the notification objectpublic static org.reactivestreams.Subscription getSubscription(java.lang.Object o)
o - the notification objectpublic static Disposable getDisposable(java.lang.Object o)
public static <T> boolean accept(java.lang.Object o,
org.reactivestreams.Subscriber<? super T> s)
Does not check for a subscription notification, see acceptFull(Object, Subscriber).
T - the expected value type when unwrappedo - the notification objects - the subscriber to call methods onacceptFull(Object, Subscriber)public static <T> boolean accept(java.lang.Object o,
NbpObservable.NbpSubscriber<? super T> s)
Does not check for a subscription notification.
T - the expected value type when unwrappedo - the notification objects - the NbpSubscriber to call methods onpublic static <T> boolean acceptFull(java.lang.Object o,
org.reactivestreams.Subscriber<? super T> s)
T - the expected value type when unwrappedo - the notification objects - the subscriber to call methods onaccept(Object, Subscriber)public static <T> boolean acceptFull(java.lang.Object o,
NbpObservable.NbpSubscriber<? super T> s)
T - the expected value type when unwrappedo - the notification objects - the subscriber to call methods on#accept(Object, NbpSubscriber)