All Classes and Interfaces

Interfaces
Class
Description
A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.
A Publisher is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its Subscriber(s).
Will receive call to onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).
A Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.