Package io.reactivex.rxjava3.internal.util

Interface ObservableQueueDrain<T,U>

All Known Implementing Classes:
ObservableBufferExactBoundary.BufferExactBoundaryObserver, ObservableBufferTimed.BufferExactBoundedObserver, ObservableBufferTimed.BufferExactUnboundedObserver, ObservableBufferTimed.BufferSkipBoundedObserver, QueueDrainObserver
public interface ObservableQueueDrain<T,U>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accept(Observer<? super U> a, T v)
    Accept the value and return true if forwarded.
    boolean
    cancelled()
     
    boolean
    done()
     
    boolean
    enter()
     
    Throwable
    error()
     
    int
    leave(int m)
    Adds m to the wip counter.

  • Method Details

    • cancelled

      boolean cancelled()

    • done

      boolean done()

    • error

      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