- All Implemented Interfaces:
- org.reactivestreams.Publisher<T>
- Direct Known Subclasses:
- InfiniteIncrementNumberPublisher, NumberIterablePublisher
public class AsyncIterablePublisher<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<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`.
NOTE: The code below uses a lot of try-catches to show the reader where exceptions can be expected, and where they are forbidden.