Class BasicQueueDisposable<T>

java.lang.Object
io.reactivex.rxjava3.internal.observers.BasicQueueDisposable<T>
Type Parameters:
T - the output value type
All Implemented Interfaces:
Disposable, QueueDisposable<T>, QueueFuseable<T>, SimpleQueue<T>
Direct Known Subclasses:
MaybeFlatMapIterableObservable.FlatMapIterableObserver, ObservableFromArray.FromArrayDisposable, ObservableFromIterable.FromIterableDisposable

public abstract class BasicQueueDisposable<T> extends Object implements QueueDisposable<T>
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
  • Constructor Details

    • BasicQueueDisposable

      public BasicQueueDisposable()
  • Method Details

    • offer

      public final boolean offer(T e)
      Description copied from interface: SimpleQueue
      Atomically enqueue a single value.
      Specified by:
      offer in interface SimpleQueue<T>
      Parameters:
      e - the value to enqueue, not null
      Returns:
      true if successful, false if the value was not enqueued likely due to reaching the queue capacity)
    • offer

      public final boolean offer(T v1, T v2)
      Description copied from interface: SimpleQueue
      Atomically enqueue two values.
      Specified by:
      offer in interface SimpleQueue<T>
      Parameters:
      v1 - the first value to enqueue, not null
      v2 - the second value to enqueue, not null
      Returns:
      true if successful, false if the value was not enqueued likely due to reaching the queue capacity)