Class AsyncIterablePublisher<T>

java.lang.Object
org.reactivestreams.example.unicast.AsyncIterablePublisher<T>
All Implemented Interfaces:
Publisher<T>
Direct Known Subclasses:
HelperPublisher, InfiniteHelperPublisher, InfiniteIncrementNumberPublisher, NumberIterablePublisher

public class AsyncIterablePublisher<T> extends Object implements 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.