Class BrokerIterator<T,​O>

  • Type Parameters:
    T - the type parameter
    O - the type parameter
    All Implemented Interfaces:
    Iterator<O>

    public class BrokerIterator<T,​O>
    extends Object
    implements Iterator<O>
    The type Broker iterator.
    • Constructor Detail

      • BrokerIterator

        public BrokerIterator​(Broker.Producer<T> producer,
                              Function<? super T,​Stream<? extends O>> converter,
                              int bufferSize,
                              int nThreads)
        Instantiates a new Broker iterator.
        Parameters:
        producer - the producer
        converter - the converter
        nThreads - the n threads
    • Method Detail

      • hasNext

        public boolean hasNext()
        Specified by:
        hasNext in interface Iterator<T>
      • next

        public O next()
        Specified by:
        next in interface Iterator<T>