public abstract Class BasicIntQueueDisposable<T>

Class Inheritance

extends AtomicInteger
implements QueueDisposable<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable

All Implemented Interfaces

io.reactivex.rxjava3.operators.QueueDisposable, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.operators.QueueFuseable, io.reactivex.rxjava3.operators.SimpleQueue

Known Direct Subclasses

Type Parameters

<T>: the output value type

Imports

java.util.concurrent.atomic.AtomicInteger, io.reactivex.rxjava3.operators.QueueDisposable

An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Summary

Access	Constructor and Description
public	BasicIntQueueDisposable()

Method Summary

Modifier and Type	Method and Description
public final boolean	offer(T the value to enqueue, not null e) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue a single value.
public final boolean	offer(T the first value to enqueue, not null v1, T the second value to enqueue, not null v2) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue two values.

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Detail

BasicIntQueueDisposable	back to summary
public BasicIntQueueDisposable()

Method Detail

offer	back to summary
public final boolean offer(T e) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue a single value. Parameters e:T the value to enqueue, not null Returns:boolean true if successful, false if the value was not enqueued likely due to reaching the queue capacity) Annotations @Override

offer

back to summary

public final boolean offer(T e)

Implements io.reactivex.rxjava3.operators.SimpleQueue.offer.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer.

Atomically enqueue a single value.

Parameters

e:T: the value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations

@Override

offer	back to summary
public final boolean offer(T v1, T v2) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue two values. Parameters v1:T the first value to enqueue, not null v2:T the second value to enqueue, not null Returns:boolean true if successful, false if the value was not enqueued likely due to reaching the queue capacity) Annotations @Override