Class QueueDrainSubscriber<T,​U,​V>

    • Field Detail

      • downstream

        protected final org.reactivestreams.Subscriber<? super V> downstream
      • cancelled

        protected volatile boolean cancelled
      • done

        protected volatile boolean done
      • error

        protected java.lang.Throwable error
    • Constructor Detail

      • QueueDrainSubscriber

        public QueueDrainSubscriber​(org.reactivestreams.Subscriber<? super V> actual,
                                    SimplePlainQueue<U> queue)
    • Method Detail

      • done

        public final boolean done()
        Specified by:
        done in interface QueueDrain<T,​U>
      • enter

        public final boolean enter()
        Specified by:
        enter in interface QueueDrain<T,​U>
      • fastEnter

        public final boolean fastEnter()
      • fastPathEmitMax

        protected final void fastPathEmitMax​(U value,
                                             boolean delayError,
                                             Disposable dispose)
      • fastPathOrderedEmitMax

        protected final void fastPathOrderedEmitMax​(U value,
                                                    boolean delayError,
                                                    Disposable dispose)
      • accept

        public boolean accept​(org.reactivestreams.Subscriber<? super V> a,
                              U v)
        Description copied from interface: QueueDrain
        Accept the value and return true if forwarded.
        Specified by:
        accept in interface QueueDrain<T,​U>
        Parameters:
        a - the subscriber
        v - the value
        Returns:
        true if the value was delivered
      • error

        public final java.lang.Throwable error()
        Specified by:
        error in interface QueueDrain<T,​U>
      • leave

        public final int leave​(int m)
        Description copied from interface: QueueDrain
        Adds m to the wip counter.
        Specified by:
        leave in interface QueueDrain<T,​U>
        Parameters:
        m - the value to add
        Returns:
        the current value after adding m
      • produced

        public final long produced​(long n)
        Specified by:
        produced in interface QueueDrain<T,​U>
      • requested

        public final void requested​(long n)