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 Details

    • disposed

      volatile boolean disposed
  • Constructor Details

    • CancellableQueueFuseable

      public CancellableQueueFuseable()
  • Method Details