public class DelegatingSubscription extends Object implements org.reactivestreams.Subscription
DelegatingSubscription(org.reactivestreams.Subscription upstreamSubscription)
void
cancel()
request(long n)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public DelegatingSubscription(org.reactivestreams.Subscription upstreamSubscription)
public void request(long n)
request
org.reactivestreams.Subscription
public void cancel()
cancel
Copyright © 2019. All rights reserved.