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
,Serializable
,Runnable
- Enclosing class:
FlowableDebounceTimed<T>
static final class FlowableDebounceTimed.DebounceEmitter<T>
extends AtomicReference<Disposable>
implements Runnable, Disposable
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final long
(package private) final AtomicBoolean
(package private) final FlowableDebounceTimed.DebounceTimedSubscriber
<T> private static final long
(package private) final T
-
Constructor Summary
ConstructorsConstructorDescriptionDebounceEmitter
(T value, long idx, FlowableDebounceTimed.DebounceTimedSubscriber<T> parent) -
Method Summary
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 Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
value
-
idx
final long idx -
parent
-
once
-
-
Constructor Details
-
DebounceEmitter
DebounceEmitter(T value, long idx, FlowableDebounceTimed.DebounceTimedSubscriber<T> parent)
-
-
Method Details
-
run
public void run() -
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
-