public class SimpleSubscription
extends java.lang.Object
implements org.reactivestreams.Subscription
构造器和说明 |
---|
SimpleSubscription() |
限定符和类型 | 方法和说明 |
---|---|
void |
cancel() |
boolean |
isCancelled() |
SimpleSubscription |
onRequest(java.util.function.BiConsumer<SimpleSubscription,java.lang.Long> onRequest) |
void |
request(long l) |
public SimpleSubscription onRequest(java.util.function.BiConsumer<SimpleSubscription,java.lang.Long> onRequest)
public boolean isCancelled()
public void request(long l)
request
在接口中 org.reactivestreams.Subscription
public void cancel()
cancel
在接口中 org.reactivestreams.Subscription