Class QueueDrainObserver<T,​U,​V>

    • Field Detail

      • downstream

        protected final Observer<? super V> downstream
      • cancelled

        protected volatile boolean cancelled
      • done

        protected volatile boolean done
      • error

        protected java.lang.Throwable error
    • Method Detail

      • fastPathEmit

        protected final void fastPathEmit​(U value,
                                          boolean delayError,
                                          Disposable dispose)
      • fastPathOrderedEmit

        protected final void fastPathOrderedEmit​(U value,
                                                 boolean delayError,
                                                 Disposable disposable)
        Makes sure the fast-path emits in order.
        Parameters:
        value - the value to emit or queue up
        delayError - if true, errors are delayed until the source has terminated
        disposable - the resource to dispose if the drain terminates
      • leave

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

        public void accept​(Observer<? super V> a,
                           U v)
        Description copied from interface: ObservableQueueDrain
        Accept the value and return true if forwarded.
        Specified by:
        accept in interface ObservableQueueDrain<T,​U>
        Parameters:
        a - the subscriber to deliver values to
        v - the value to deliver