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
Represents an empty, async-only
QueueFuseable
instance that tracks and exposes a
canceled/disposed state.- Since:
- 3.0.0
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable
clear, isEmpty, offer, offer, poll, request, requestFusion
-
Field Details
-
disposed
volatile boolean disposed
-
-
Constructor Details
-
CancellableQueueFuseable
public CancellableQueueFuseable()
-
-
Method Details
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
- Overrides:
cancel
in classAbstractEmptyQueueFuseable<T>
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
- Overrides:
dispose
in classAbstractEmptyQueueFuseable<T>
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Overrides:
isDisposed
in classAbstractEmptyQueueFuseable<T>
- Returns:
- true if this resource has been disposed
-