Top Description Constructors Methods
io.reactivex.rxjava3.internal.observers

public abstract Class BasicQueueDisposable<T>

extends Object
implements QueueDisposable<T>
Class Inheritance
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
io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapIterableObservable.FlatMapIterableObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFromArray.FromArrayDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableFromIterable.FromIterableDisposable
Type Parameters
<T>
the output value type
Imports
io.reactivex.rxjava3.operators.QueueDisposable
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.

Constructor Summary

AccessConstructor and Description
public
BasicQueueDisposable()

Method Summary

Modifier and TypeMethod 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.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

BasicQueueDisposableback to summary
public BasicQueueDisposable()

Method Detail

offerback 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
offerback 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