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>
AProcessor
represents a processing stage—which is both aSubscriber
and aPublisher
and obeys the contracts of both.Classes in org.reactivestreams that implement Subscriber Modifier and Type Class Description (package private) static class
FlowAdapters.ReactiveToFlowProcessor<T,U>
Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.(package private) static 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) Subscriber<? super T>
FlowAdapters.FlowToReactiveSubscriber. reactiveStreams
Methods in org.reactivestreams that return Subscriber Modifier and Type Method Description static <T> Subscriber<T>
FlowAdapters. toSubscriber(java.util.concurrent.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)
RequestPublisher
to start streaming data.static <T> java.util.concurrent.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 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) Subscriber<? super java.lang.Integer>
RangePublisher.RangeSubscription. downstream
The Subscriber we are emitting integer values to.(package private) 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 java.lang.Integer> subscriber)
Constructors in org.reactivestreams.example.unicast with parameters of type Subscriber Constructor Description RangeSubscription(Subscriber<? super java.lang.Integer> downstream, int start, int end)
Constructs a stateful RangeSubscription that emits signals to the given downstream from an integer range of [start, end).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 asSubscriber
decorator and should be used inpub.subscriber(...)
calls, in order to allow intercepting calls on the underlyingSubscriber
.static class
TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T>
Similar toTestEnvironment.ManualSubscriberWithSubscriptionSupport
but does not accumulate values signalled viaonNext
, 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 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)
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 Constructor Description BlackboxSubscriberProxy(TestEnvironment env, Subscriber<T> subscriber)
Constructor parameters in org.reactivestreams.tck with type arguments of type Subscriber 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 Subscriber<T>
FlowSubscriberBlackboxVerification. createSubscriber()
Subscriber<T>
FlowSubscriberWhiteboxVerification. createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)
Methods in org.reactivestreams.tck.flow with parameters of type Subscriber Modifier and Type Method Description void
FlowSubscriberBlackboxVerification. triggerRequest(Subscriber<? super T> subscriber)
-