Uses of Interface
org.reactivestreams.Subscriber
Packages that use Subscriber
Package
Description
-
Uses of Subscriber in org.reactivestreams
Subinterfaces of Subscriber in org.reactivestreamsModifier and TypeInterfaceDescriptioninterface
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 SubscriberModifier and TypeClassDescription(package private) static final class
Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.(package private) static final class
Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.Fields in org.reactivestreams declared as SubscriberModifier and TypeFieldDescription(package private) final Subscriber
<? super T> FlowAdapters.FlowToReactiveSubscriber.reactiveStreams
Methods in org.reactivestreams that return SubscriberModifier and TypeMethodDescriptionstatic <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 SubscriberModifier and TypeMethodDescriptionvoid
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> 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 -
Uses of Subscriber in org.reactivestreams.example.unicast
Classes in org.reactivestreams.example.unicast that implement SubscriberModifier and TypeClassDescriptionclass
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 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 SubscriberModifier and TypeFieldDescription(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 SubscriberModifier and TypeMethodDescriptionvoid
AsyncIterablePublisher.subscribe
(Subscriber<? super T> s) void
RangePublisher.subscribe
(Subscriber<? super Integer> subscriber) Constructors in org.reactivestreams.example.unicast with parameters of type SubscriberModifierConstructorDescription(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 SubscriberModifier and TypeClassDescriptionclass
static class
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
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
Subscriber
implementation which can be steered by test code and asserted on.static class
static class
Fields in org.reactivestreams.tck with type parameters of type SubscriberModifier and TypeFieldDescriptionprotected 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 SubscriberModifier and TypeMethodDescriptionIdentityProcessorVerification.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 SubscriberModifier and TypeMethodDescriptionSubscriberBlackboxVerification.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 SubscriberModifierConstructorDescriptionBlackboxSubscriberProxy
(TestEnvironment env, Subscriber<T> subscriber) Constructor parameters in org.reactivestreams.tck with type arguments of type SubscriberModifierConstructorDescriptionBlackboxProbe
(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 SubscriberModifier and TypeMethodDescriptionfinal Subscriber
<T> FlowSubscriberBlackboxVerification.createSubscriber()
final Subscriber
<T> FlowSubscriberWhiteboxVerification.createSubscriber
(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe) Methods in org.reactivestreams.tck.flow with parameters of type SubscriberModifier and TypeMethodDescriptionfinal void
FlowSubscriberBlackboxVerification.triggerRequest
(Subscriber<? super T> subscriber)