Class CancellableQueueFuseable<T>

java.lang.Object

io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable<T>

io.reactivex.rxjava3.internal.fuseable.CancellableQueueFuseable<T>

Type Parameters:

T - the output value type

All Implemented Interfaces:

Disposable, QueueDisposable<T>, QueueFuseable<T>, QueueSubscription<T>, SimpleQueue<T>, org.reactivestreams.Subscription

public final class CancellableQueueFuseable<T>
extends AbstractEmptyQueueFuseable<T>

Represents an empty, async-only QueueFuseable instance that tracks and exposes a canceled/disposed state.

Since:

3.0.0

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	disposed

Fields inherited from interface QueueFuseable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor	Description
CancellableQueueFuseable()

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	dispose()	Dispose the resource, the operation should be idempotent.
boolean	isDisposed()	Returns true if this resource has been disposed.

Methods inherited from class AbstractEmptyQueueFuseable

clear, isEmpty, offer, offer, poll, request, requestFusion

Methods inherited from class Object

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

Field Details

disposed

volatile boolean disposed

Constructor Details

CancellableQueueFuseable

public CancellableQueueFuseable()

Method Details

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

Overrides:

cancel in class AbstractEmptyQueueFuseable<T>

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

Overrides:

dispose in class AbstractEmptyQueueFuseable<T>

isDisposed

public boolean isDisposed()

Description copied from interface: Disposable

Returns true if this resource has been disposed.

Specified by:

isDisposed in interface Disposable

Overrides:

isDisposed in class AbstractEmptyQueueFuseable<T>

Returns:

true if this resource has been disposed