public static <T> Iterator<T> toIteratorWithRequestsPipelineSize(final Publisher<T> publisher,
                                                                     final int numRequestsPipeline) {
        return new StreamToIterator<>(publisher, numRequestsPipeline);
    }
public static < T > Iterator < T > toIteratorWithRequestsPipelineSize ( final Publisher < T > publisher , final int numRequestsPipeline ) { return new StreamToIterator < > ( publisher , numRequestsPipeline ) ; }
@param publisher           pulisher that we are adapting as a blocking Iterator
@param numRequestsPipeline how many messages we will accept up to
@param <T>                 T
@return Iterator that wraps the pulisher with a blocking interface.