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
An abstract QueueDisposable implementation that defaults all
unnecessary Queue methods to throw UnsupportedOperationException.
-
Field Summary
-
Constructor Summary
Constructors -
Method Summary
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
-
Constructor Details
-
BasicQueueDisposable
public BasicQueueDisposable()
-
-
Method Details
-
offer
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
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)
-