private static enum ChannelSendOperator.State extends java.lang.Enum<ChannelSendOperator.State>
Enum Constant and Description |
---|
EMITTING_CACHED_SIGNALS
The write subscriber has subscribed and requested; we're going to
emit the cached signals.
|
FIRST_SIGNAL_RECEIVED
At least one signal of any kind has been received; we're ready to
call the write function and proceed with actual writing.
|
NEW
No emissions from the upstream source yet
|
READY_TO_WRITE
The write subscriber has subscribed, and cached signals have been
emitted to it; we're ready to switch to a simple pass-through mode
for all remaining signals.
|
Modifier and Type | Method and Description |
---|---|
static ChannelSendOperator.State |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ChannelSendOperator.State[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final ChannelSendOperator.State NEW
public static final ChannelSendOperator.State FIRST_SIGNAL_RECEIVED
public static final ChannelSendOperator.State EMITTING_CACHED_SIGNALS
public static final ChannelSendOperator.State READY_TO_WRITE
public static ChannelSendOperator.State[] values()
for (ChannelSendOperator.State c : ChannelSendOperator.State.values()) System.out.println(c);
public static ChannelSendOperator.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