Class SingleTimer.TimerDisposable
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<Disposable>
-
- io.reactivex.rxjava3.internal.operators.single.SingleTimer.TimerDisposable
-
- All Implemented Interfaces:
Disposable,java.io.Serializable,java.lang.Runnable
- Enclosing class:
- SingleTimer
static final class SingleTimer.TimerDisposable extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Disposable, java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) SingleObserver<? super java.lang.Long>downstreamprivate static longserialVersionUID
-
Constructor Summary
Constructors Constructor Description TimerDisposable(SingleObserver<? super java.lang.Long> downstream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddispose()Dispose the resource, the operation should be idempotent.booleanisDisposed()Returns true if this resource has been disposed.voidrun()(package private) voidsetFuture(Disposable d)-
Methods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final SingleObserver<? super java.lang.Long> downstream
-
-
Constructor Detail
-
TimerDisposable
TimerDisposable(SingleObserver<? super java.lang.Long> downstream)
-
-
Method Detail
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
dispose
public void dispose()
Description copied from interface:DisposableDispose the resource, the operation should be idempotent.- Specified by:
disposein interfaceDisposable
-
isDisposed
public boolean isDisposed()
Description copied from interface:DisposableReturns true if this resource has been disposed.- Specified by:
isDisposedin interfaceDisposable- Returns:
- true if this resource has been disposed
-
setFuture
void setFuture(Disposable d)
-
-