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 calling Publisher.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)