Uses of Interface
org.reactivestreams.Subscription
-
Packages that use Subscription Package Description org.reactivestreams org.reactivestreams.example.unicast org.reactivestreams.tck -
-
Uses of Subscription in org.reactivestreams
Classes in org.reactivestreams that implement Subscription Modifier and Type Class Description (package private) static class
FlowAdapters.ReactiveToFlowSubscription
Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.Fields in org.reactivestreams declared as Subscription Modifier and Type Field Description (package private) Subscription
FlowAdapters.FlowToReactiveSubscription. reactiveStreams
Methods in org.reactivestreams with parameters of type Subscription Modifier and Type Method Description void
FlowAdapters.ReactiveToFlowProcessor. onSubscribe(Subscription subscription)
void
FlowAdapters.ReactiveToFlowSubscriber. onSubscribe(Subscription subscription)
void
Subscriber. onSubscribe(Subscription s)
Invoked after callingPublisher.subscribe(Subscriber)
.Constructors in org.reactivestreams with parameters of type Subscription Constructor Description FlowToReactiveSubscription(Subscription reactive)
-
Uses of Subscription in org.reactivestreams.example.unicast
Classes in org.reactivestreams.example.unicast that implement Subscription Modifier and Type Class Description (package private) class
AsyncIterablePublisher.SubscriptionImpl
(package private) static class
RangePublisher.RangeSubscription
A Subscription implementation that holds the current downstream requested amount and responds to the downstream's request() and cancel() calls.Fields in org.reactivestreams.example.unicast declared as Subscription Modifier and Type Field Description Subscription
AsyncSubscriber.OnSubscribe. subscription
private Subscription
AsyncSubscriber. subscription
private Subscription
SyncSubscriber. subscription
Methods in org.reactivestreams.example.unicast with parameters of type Subscription Modifier and Type Method Description private void
AsyncSubscriber. handleOnSubscribe(Subscription s)
void
AsyncSubscriber. onSubscribe(Subscription s)
void
SyncSubscriber. onSubscribe(Subscription s)
Constructors in org.reactivestreams.example.unicast with parameters of type Subscription Constructor Description OnSubscribe(Subscription subscription)
-
Uses of Subscription in org.reactivestreams.tck
Fields in org.reactivestreams.tck with type parameters of type Subscription Modifier and Type Field Description (package private) TestEnvironment.Promise<Subscription>
TestEnvironment.TestSubscriber. subscription
Methods in org.reactivestreams.tck with parameters of type Subscription Modifier and Type Method Description void
SubscriberWhiteboxVerification.BlackboxSubscriberProxy. onSubscribe(Subscription s)
void
TestEnvironment.ManualSubscriberWithSubscriptionSupport. onSubscribe(Subscription s)
void
TestEnvironment.TestSubscriber. onSubscribe(Subscription subscription)
-