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 final 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) final 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

Modifier	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) final class	AsyncIterablePublisher.SubscriptionImpl
(package private) static final 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
final 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 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

Modifier	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) final 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)