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 java.lang.Object implements QueueDisposable<T>
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
-
-
Constructor Summary
Constructors Constructor Description BasicQueueDisposable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
offer(T e)
Atomically enqueue a single value.boolean
offer(T v1, T v2)
Atomically enqueue two values.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.reactivex.rxjava3.disposables.Disposable
dispose, isDisposed
-
Methods inherited from interface io.reactivex.rxjava3.operators.QueueFuseable
requestFusion
-
Methods inherited from interface io.reactivex.rxjava3.operators.SimpleQueue
clear, isEmpty, poll
-
-
-
-
Method Detail
-
offer
public final boolean offer(T e)
Description copied from interface:SimpleQueue
Atomically enqueue a single value.- Specified by:
offer
in interfaceSimpleQueue<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 interfaceSimpleQueue<T>
- Parameters:
v1
- the first value to enqueue, not nullv2
- 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)
-
-