Uses of Interface
org.reactivestreams.Subscription
Packages that use Subscription
-
Uses of Subscription in org.reactivestreams
Classes in org.reactivestreams that implement SubscriptionModifier and TypeClassDescription(package private) static final class
Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.Fields in org.reactivestreams declared as SubscriptionModifier and TypeFieldDescription(package private) final Subscription
FlowAdapters.FlowToReactiveSubscription.reactiveStreams
Methods in org.reactivestreams with parameters of type SubscriptionModifier and TypeMethodDescriptionvoid
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 -
Uses of Subscription in org.reactivestreams.example.unicast
Classes in org.reactivestreams.example.unicast that implement SubscriptionModifier and TypeClassDescription(package private) final class
(package private) static final class
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 SubscriptionModifier and TypeFieldDescriptionfinal Subscription
AsyncSubscriber.OnSubscribe.subscription
private Subscription
AsyncSubscriber.subscription
private Subscription
SyncSubscriber.subscription
Methods in org.reactivestreams.example.unicast with parameters of type SubscriptionModifier and TypeMethodDescriptionprivate final void
AsyncSubscriber.handleOnSubscribe
(Subscription s) final void
AsyncSubscriber.onSubscribe
(Subscription s) void
SyncSubscriber.onSubscribe
(Subscription s) Constructors in org.reactivestreams.example.unicast with parameters of type Subscription -
Uses of Subscription in org.reactivestreams.tck
Fields in org.reactivestreams.tck with type parameters of type SubscriptionModifier and TypeFieldDescription(package private) final TestEnvironment.Promise
<Subscription> TestEnvironment.TestSubscriber.subscription
Methods in org.reactivestreams.tck with parameters of type SubscriptionModifier and TypeMethodDescriptionvoid
SubscriberWhiteboxVerification.BlackboxSubscriberProxy.onSubscribe
(Subscription s) void
TestEnvironment.ManualSubscriberWithSubscriptionSupport.onSubscribe
(Subscription s) void
TestEnvironment.TestSubscriber.onSubscribe
(Subscription subscription)