Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.fuseable

public final Class CancellableQueueFuseable<T>

extends AbstractEmptyQueueFuseable<T>
Class Inheritance
Type Parameters
<T>
the output value type
Imports
io.reactivex.rxjava3.operators.QueueFuseable
Represents an empty, async-only QueueFuseable instance that tracks and exposes a canceled/disposed state.
Since
3.0.0

Field Summary

Modifier and TypeField and Description
pack-priv volatile boolean
disposed

Constructor Summary

AccessConstructor and Description
public
CancellableQueueFuseable()

Method Summary

Modifier and TypeMethod and Description
public void
cancel()

Overrides io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable.cancel.

Implements org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.
public void
dispose()

Overrides io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable.dispose.

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
public boolean
isDisposed()

Overrides io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable.isDisposed.

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
Inherited from io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable:
clearisEmptyofferofferpollrequestrequestFusion

Field Detail

disposedback to summary
pack-priv volatile boolean disposed

Constructor Detail

CancellableQueueFuseableback to summary
public CancellableQueueFuseable()

Method Detail

cancelback to summary
public void cancel()

Overrides io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable.cancel.

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations
@Override
disposeback to summary
public void dispose()

Overrides io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable.dispose.

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Overrides io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable.isDisposed.

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override