Interface ObservableQueueDrain<T,​U>

    • Method Detail

      • cancelled

        boolean cancelled()
      • done

        boolean done()
      • error

        java.lang.Throwable error()
      • enter

        boolean enter()
      • leave

        int leave​(int m)
        Adds m to the wip counter.
        Parameters:
        m - the value to add
        Returns:
        the wip value after adding the value
      • accept

        void accept​(Observer<? super U> a,
                    T v)
        Accept the value and return true if forwarded.
        Parameters:
        a - the subscriber to deliver values to
        v - the value to deliver