private static final class AbstractListenerReadPublisher.ReadSubscription
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private AbstractListenerReadPublisher<?> |
publisher |
Constructor and Description |
---|
ReadSubscription(AbstractListenerReadPublisher<?> publisher) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
request(long n) |
private AbstractListenerReadPublisher.State |
state() |
private final AbstractListenerReadPublisher<?> publisher
public ReadSubscription(AbstractListenerReadPublisher<?> publisher)
public final void request(long n)
public final void cancel()
private AbstractListenerReadPublisher.State state()