protected class SingleThreadedBufferingSubscriber.DownstreamSubscription extends Object implements Subscription
Modifier | Constructor and Description |
---|---|
protected |
DownstreamSubscription() |
public void request(long n)
request
in interface Subscription
public void cancel()
cancel
in interface Subscription