Package org.reactivestreams.example.unicast
-
Interface Summary Interface Description AsyncIterablePublisher.Signal AsyncSubscriber.Signal -
Class Summary Class Description AsyncIterablePublisher<T> AsyncIterablePublisher is an implementation of Reactive Streams `Publisher` which executes asynchronously, using a provided `Executor` and produces elements from a given `Iterable` in a "unicast" configuration to its `Subscribers`.AsyncIterablePublisher.Request 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.AsyncSubscriber.OnError AsyncSubscriber.OnNext<T> AsyncSubscriber.OnSubscribe InfiniteIncrementNumberPublisher NumberIterablePublisher RangePublisher A synchronous implementation of thePublisher
that can be subscribed to multiple times and each individual subscription will receive range of monotonically increasing integer values on demand.RangePublisher.RangeSubscription A Subscription implementation that holds the current downstream requested amount and responds to the downstream's request() and cancel() calls.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. -
Enum Summary Enum Description AsyncIterablePublisher.Cancel AsyncIterablePublisher.Send AsyncIterablePublisher.Subscribe AsyncSubscriber.OnComplete