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.

Field Summary

Fields inherited from interface QueueFuseable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor	Description
BasicQueueDisposable()

Method Summary

Modifier and Type	Method	Description
final boolean	offer(T e)	Atomically enqueue a single value.
final boolean	offer(T v1, T v2)	Atomically enqueue two values.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Disposable

dispose, isDisposed

Methods inherited from interface QueueFuseable

requestFusion

Methods inherited from interface SimpleQueue

clear, isEmpty, poll

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)