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
     
    boolean
     
    boolean
     
     
    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