Interface Subscriber<T>

Type Parameters:
T - the type of element signaled
All Known Subinterfaces:
Processor<T,R>
All Known Implementing Classes:
AsyncSubscriber, FlowAdapters.ReactiveToFlowProcessor, FlowAdapters.ReactiveToFlowSubscriber, IdentityProcessorVerification.ManualSubscriberWithErrorCollection, SubscriberWhiteboxVerification.BlackboxSubscriberProxy, SyncSubscriber, TestEnvironment.BlackholeSubscriberWithSubscriptionSupport, TestEnvironment.ManualSubscriber, TestEnvironment.ManualSubscriberWithSubscriptionSupport, TestEnvironment.TestSubscriber

public interface Subscriber<T>
Will receive call to onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).

No further notifications will be received until Subscription.request(long) is called.

After signaling demand:

Demand can be signaled via Subscription.request(long) whenever the Subscriber instance is capable of handling more.