Class ValveIterator<T>

  • Type Parameters:
    T - Type of elements
    All Implemented Interfaces:
    Iterator<T>

    public class ValveIterator<T>
    extends Object
    implements Iterator<T>
    Transforms reactive Valve into a blocking Iterator.

    If the original Valve ends with Throwable then this iterator simply ends and original cause can be get using getThrowable() method.

    • Method Detail

      • hasNext

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

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

        public Throwable getThrowable()
        If original Valve ends with error then this method returns cause of such error.
        Returns:
        the cause of Valve error or null