private static enum AbstractListenerWriteFlushProcessor.State extends java.lang.Enum<AbstractListenerWriteFlushProcessor.State>
Modifier and Type | Class and Description |
---|---|
private static class |
AbstractListenerWriteFlushProcessor.State.WriteSubscriber |
Enum Constant and Description |
---|
COMPLETED |
RECEIVED |
REQUESTED |
UNSUBSCRIBED |
Modifier and Type | Method and Description |
---|---|
<T> void |
onComplete(AbstractListenerWriteFlushProcessor<T> processor) |
<T> void |
onError(AbstractListenerWriteFlushProcessor<T> processor,
java.lang.Throwable ex) |
<T> void |
onNext(AbstractListenerWriteFlushProcessor<T> processor,
<any> publisher) |
<T> void |
onSubscribe(AbstractListenerWriteFlushProcessor<T> processor,
Subscription subscription) |
static AbstractListenerWriteFlushProcessor.State |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static AbstractListenerWriteFlushProcessor.State[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
<T> void |
writeComplete(AbstractListenerWriteFlushProcessor<T> processor) |
public static final AbstractListenerWriteFlushProcessor.State UNSUBSCRIBED
public static final AbstractListenerWriteFlushProcessor.State REQUESTED
public static final AbstractListenerWriteFlushProcessor.State RECEIVED
public static final AbstractListenerWriteFlushProcessor.State COMPLETED
public static AbstractListenerWriteFlushProcessor.State[] values()
for (AbstractListenerWriteFlushProcessor.State c : AbstractListenerWriteFlushProcessor.State.values()) System.out.println(c);
public static AbstractListenerWriteFlushProcessor.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 nullpublic <T> void onSubscribe(AbstractListenerWriteFlushProcessor<T> processor, Subscription subscription)
public <T> void onNext(AbstractListenerWriteFlushProcessor<T> processor, <any> publisher)
public <T> void onError(AbstractListenerWriteFlushProcessor<T> processor, java.lang.Throwable ex)
public <T> void onComplete(AbstractListenerWriteFlushProcessor<T> processor)
public <T> void writeComplete(AbstractListenerWriteFlushProcessor<T> processor)