Uses of Interface
org.reactivestreams.Subscriber

Packages that use Subscriber

Package	Description
org.reactivestreams
org.reactivestreams.example.unicast
org.reactivestreams.tck
org.reactivestreams.tck.flow

Uses of Subscriber in org.reactivestreams

Subinterfaces of Subscriber in org.reactivestreams

Modifier and Type	Interface	Description
interface	Processor<T,R>	A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.

Classes in org.reactivestreams that implement Subscriber

Modifier and Type	Class	Description
(package private) static final class	FlowAdapters.ReactiveToFlowProcessor<T,U>	Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.
(package private) static final class	FlowAdapters.ReactiveToFlowSubscriber<T>	Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.

Fields in org.reactivestreams declared as Subscriber

Modifier and Type	Field	Description
(package private) final Subscriber<? super T>	FlowAdapters.FlowToReactiveSubscriber.reactiveStreams

Methods in org.reactivestreams that return Subscriber

Modifier and Type	Method	Description
static <T> Subscriber<T>	FlowAdapters.toSubscriber(Flow.Subscriber<T> flowSubscriber)	Converts a Flow Subscriber into a Reactive Streams Subscriber.

Methods in org.reactivestreams with parameters of type Subscriber

Modifier and Type	Method	Description
void	FlowAdapters.ReactivePublisherFromFlow.subscribe(Subscriber<? super T> reactive)
void	FlowAdapters.ReactiveToFlowProcessor.subscribe(Subscriber<? super U> s)
void	Publisher.subscribe(Subscriber<? super T> s)	Request Publisher to start streaming data.
static <T> Flow.Subscriber<T>	FlowAdapters.toFlowSubscriber(Subscriber<T> reactiveStreamsSubscriber)	Converts a Reactive Streams Subscriber into a Flow Subscriber.

Constructors in org.reactivestreams with parameters of type Subscriber

Modifier	Constructor	Description
	FlowToReactiveSubscriber(Subscriber<? super T> reactive)

Uses of Subscriber in org.reactivestreams.example.unicast

Classes in org.reactivestreams.example.unicast that implement Subscriber

Modifier and Type	Class	Description
class	AsyncSubscriber<T>	AsyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs asynchronously (on an Executor), requests one element at a time, and invokes a user-defined method to process each element.
class	SyncSubscriber<T>	SyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs synchronously (on the Publisher's thread) and requests one element at a time and invokes a user-defined method to process each element.

Fields in org.reactivestreams.example.unicast declared as Subscriber

Modifier and Type	Field	Description
(package private) final Subscriber<? super Integer>	RangePublisher.RangeSubscription.downstream	The Subscriber we are emitting integer values to.
(package private) final Subscriber<? super T>	AsyncIterablePublisher.SubscriptionImpl.subscriber

Methods in org.reactivestreams.example.unicast with parameters of type Subscriber

Modifier and Type	Method	Description
void	AsyncIterablePublisher.subscribe(Subscriber<? super T> s)
void	RangePublisher.subscribe(Subscriber<? super Integer> subscriber)

Constructors in org.reactivestreams.example.unicast with parameters of type Subscriber

Modifier	Constructor	Description
(package private)	RangeSubscription(Subscriber<? super Integer> downstream, int start, int end)	Constructs a stateful RangeSubscription that emits signals to the given downstream from an integer range of [start, end).
(package private)	SubscriptionImpl(Subscriber<? super T> subscriber)

Uses of Subscriber in org.reactivestreams.tck

Classes in org.reactivestreams.tck that implement Subscriber

Modifier and Type	Class	Description
class	IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>
static class	SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>	This class is intented to be used as Subscriber decorator and should be used in pub.subscriber(...) calls, in order to allow intercepting calls on the underlying Subscriber.
static class	TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T>	Similar to TestEnvironment.ManualSubscriberWithSubscriptionSupport but does not accumulate values signalled via onNext, thus it can not be used to assert values signalled to this subscriber.
static class	TestEnvironment.ManualSubscriber<T>	Subscriber implementation which can be steered by test code and asserted on.
static class	TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
static class	TestEnvironment.TestSubscriber<T>

Fields in org.reactivestreams.tck with type parameters of type Subscriber

Modifier and Type	Field	Description
protected final TestEnvironment.Promise<Subscriber<? super T>>	SubscriberWhiteboxVerification.BlackboxProbe.subscriber
protected TestEnvironment.Promise<Subscriber<? super T>>	TestEnvironment.ManualPublisher.subscriber

Methods in org.reactivestreams.tck that return Subscriber

Modifier and Type	Method	Description
Subscriber<T>	IdentityProcessorVerification.createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)	/////////////////// SUBSCRIBER RULES VERIFICATION ///////////////////////////
abstract Subscriber<T>	SubscriberBlackboxVerification.createSubscriber()	This is the main method you must implement in your test incarnation.
abstract Subscriber<T>	SubscriberWhiteboxVerification.createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)	This is the main method you must implement in your test incarnation.
Subscriber<? super T>	SubscriberBlackboxVerification.BlackboxTestStage.sub()
Subscriber<? super T>	SubscriberWhiteboxVerification.BlackboxProbe.sub()
Subscriber<? super T>	SubscriberWhiteboxVerification.WhiteboxTestStage.sub()

Methods in org.reactivestreams.tck with parameters of type Subscriber

Modifier and Type	Method	Description
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>	SubscriberBlackboxVerification.BlackboxTestStage.createBlackboxSubscriberProxy(TestEnvironment env, Subscriber<T> sub)
void	TestEnvironment.ManualPublisher.subscribe(Subscriber<? super T> s)
void	SubscriberBlackboxVerification.triggerRequest(Subscriber<? super T> subscriber)	Override this method if the Subscriber implementation you are verifying needs an external signal before it signals demand to its Publisher.

Constructors in org.reactivestreams.tck with parameters of type Subscriber

Modifier	Constructor	Description
	BlackboxSubscriberProxy(TestEnvironment env, Subscriber<T> subscriber)

Constructor parameters in org.reactivestreams.tck with type arguments of type Subscriber

Modifier	Constructor	Description
	BlackboxProbe(TestEnvironment env, TestEnvironment.Promise<Subscriber<? super T>> subscriber)
	WhiteboxSubscriberProbe(TestEnvironment env, TestEnvironment.Promise<Subscriber<? super T>> subscriber)

Uses of Subscriber in org.reactivestreams.tck.flow

Methods in org.reactivestreams.tck.flow that return Subscriber

Modifier and Type	Method	Description
final Subscriber<T>	FlowSubscriberBlackboxVerification.createSubscriber()
final Subscriber<T>	FlowSubscriberWhiteboxVerification.createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)

Methods in org.reactivestreams.tck.flow with parameters of type Subscriber

Modifier and Type	Method	Description
final void	FlowSubscriberBlackboxVerification.triggerRequest(Subscriber<? super T> subscriber)