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
     
    boolean
     
    boolean
     
     
    int
    leave(int m)
    Adds m to the wip counter.
    long
    produced(long n)
     
    long
     
  • 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