Class FlowableDebounceTimed.DebounceEmitter<T>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<Disposable>
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableDebounceTimed.DebounceEmitter<T>
-
- All Implemented Interfaces:
Disposable
,java.io.Serializable
,java.lang.Runnable
- Enclosing class:
- FlowableDebounceTimed<T>
static final class FlowableDebounceTimed.DebounceEmitter<T> extends java.util.concurrent.atomic.AtomicReference<Disposable> implements java.lang.Runnable, Disposable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) long
idx
(package private) java.util.concurrent.atomic.AtomicBoolean
once
(package private) FlowableDebounceTimed.DebounceTimedSubscriber<T>
parent
private static long
serialVersionUID
(package private) T
value
-
Constructor Summary
Constructors Constructor Description DebounceEmitter(T value, long idx, FlowableDebounceTimed.DebounceTimedSubscriber<T> parent)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dispose()
Dispose the resource, the operation should be idempotent.(package private) void
emit()
boolean
isDisposed()
Returns true if this resource has been disposed.void
run()
void
setResource(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
-
value
final T value
-
idx
final long idx
-
parent
final FlowableDebounceTimed.DebounceTimedSubscriber<T> parent
-
once
final java.util.concurrent.atomic.AtomicBoolean once
-
-
Constructor Detail
-
DebounceEmitter
DebounceEmitter(T value, long idx, FlowableDebounceTimed.DebounceTimedSubscriber<T> parent)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
emit
void emit()
-
dispose
public void dispose()
Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()
Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
setResource
public void setResource(Disposable d)
-
-