Package io.reactivex.rxjava3.internal.util

Interface QueueDrain<T,U>

All Known Implementing Classes:
FlowableBufferExactBoundary.BufferExactBoundarySubscriber, FlowableBufferTimed.BufferExactBoundedSubscriber, FlowableBufferTimed.BufferExactUnboundedSubscriber, FlowableBufferTimed.BufferSkipBoundedSubscriber, QueueDrainSubscriber
public interface QueueDrain<T,U>

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    accept(org.reactivestreams.Subscriber<? 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.
    long
    produced(long n)
     
    long
    requested()
     

  • Method Details

    • cancelled

      boolean cancelled()

    • done

      boolean done()

    • error

      Throwable error()

    • enter

      boolean enter()

    • requested

      long requested()

    • produced

      long produced(long n)

    • leave

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

    • accept

      boolean accept(org.reactivestreams.Subscriber<? super U> a, T v)
      Accept the value and return true if forwarded.
      Parameters:
      a - the subscriber
      v - the value
      Returns:
      true if the value was delivered