Interface Subscriber<T>

Type Parameters:
T - the type of element signaled.
All Known Subinterfaces:
Processor<T,R>

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.