private static enum AbstractListenerReadPublisher.State extends java.lang.Enum<AbstractListenerReadPublisher.State>
Publisher
to be in.
UNSUBSCRIBED | v SUBSCRIBING | v +---- NO_DEMAND ---------------> DEMAND ---+ | ^ ^ | | | | | | +------- READING <--------+ | | | | | v | +--------------> COMPLETED <---------------+
Enum Constant and Description |
---|
COMPLETED |
DEMAND |
NO_DEMAND |
READING |
SUBSCRIBING
Very brief state where we know we have a Subscriber but must not
send onComplete and onError until we after onSubscribe.
|
UNSUBSCRIBED |
Modifier and Type | Method and Description |
---|---|
(package private) <T> void |
cancel(AbstractListenerReadPublisher<T> publisher) |
(package private) <T> void |
onAllDataRead(AbstractListenerReadPublisher<T> publisher) |
(package private) <T> void |
onDataAvailable(AbstractListenerReadPublisher<T> publisher) |
(package private) <T> void |
onError(AbstractListenerReadPublisher<T> publisher,
java.lang.Throwable t) |
(package private) <T> void |
request(AbstractListenerReadPublisher<T> publisher,
long n) |
(package private) <T> void |
subscribe(AbstractListenerReadPublisher<T> publisher,
<any> subscriber) |
static AbstractListenerReadPublisher.State |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static AbstractListenerReadPublisher.State[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final AbstractListenerReadPublisher.State UNSUBSCRIBED
public static final AbstractListenerReadPublisher.State SUBSCRIBING
public static final AbstractListenerReadPublisher.State NO_DEMAND
public static final AbstractListenerReadPublisher.State DEMAND
public static final AbstractListenerReadPublisher.State READING
public static final AbstractListenerReadPublisher.State COMPLETED
public static AbstractListenerReadPublisher.State[] values()
for (AbstractListenerReadPublisher.State c : AbstractListenerReadPublisher.State.values()) System.out.println(c);
public static AbstractListenerReadPublisher.State 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 null<T> void subscribe(AbstractListenerReadPublisher<T> publisher, <any> subscriber)
<T> void request(AbstractListenerReadPublisher<T> publisher, long n)
<T> void cancel(AbstractListenerReadPublisher<T> publisher)
<T> void onDataAvailable(AbstractListenerReadPublisher<T> publisher)
<T> void onAllDataRead(AbstractListenerReadPublisher<T> publisher)
<T> void onError(AbstractListenerReadPublisher<T> publisher, java.lang.Throwable t)