Class AsyncIterablePublisher<T>

  • All Implemented Interfaces:
    Publisher<T>
    Direct Known Subclasses:
    HelperPublisher, InfiniteHelperPublisher, InfiniteIncrementNumberPublisher, NumberIterablePublisher

    public class AsyncIterablePublisher<T>
    extends java.lang.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.
    • Field Detail

      • elements

        private final java.lang.Iterable<T> elements
      • executor

        private final java.util.concurrent.Executor executor
      • batchSize

        private final int batchSize
    • Constructor Detail

      • AsyncIterablePublisher

        public AsyncIterablePublisher​(java.lang.Iterable<T> elements,
                                      java.util.concurrent.Executor executor)
      • AsyncIterablePublisher

        public AsyncIterablePublisher​(java.lang.Iterable<T> elements,
                                      int batchSize,
                                      java.util.concurrent.Executor executor)