Class BasicIntQueueDisposable<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable<T>
- Type Parameters:
T
- the output value type
- All Implemented Interfaces:
Disposable
,QueueDisposable<T>
,QueueFuseable<T>
,SimpleQueue<T>
,Serializable
- Direct Known Subclasses:
DeferredScalarDisposable
,MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver
,ObservableDoFinally.DoFinallyObserver
,ObservableFlatMapCompletable.FlatMapCompletableMainObserver
,ObservableObserveOn.ObserveOnObserver
,ObservableRange.RangeDisposable
,ObservableRangeLong.RangeDisposable
,SingleFlatMapIterableObservable.FlatMapIterableObserver
,UnicastSubject.UnicastQueueDisposable
public abstract class BasicIntQueueDisposable<T>
extends AtomicInteger
implements QueueDisposable<T>
An abstract QueueDisposable implementation, extending an AtomicInteger,
that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
- See Also:
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
Methods inherited from class java.lang.Number
byteValue, shortValue
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
-
Constructor Details
-
BasicIntQueueDisposable
public BasicIntQueueDisposable()
-
-
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)
-