Class FlowableDebounce.DebounceSubscriber.DebounceInnerSubscriber<T,U>
java.lang.Object
io.reactivex.rxjava3.subscribers.DisposableSubscriber<U>
io.reactivex.rxjava3.internal.operators.flowable.FlowableDebounce.DebounceSubscriber.DebounceInnerSubscriber<T,U>
- All Implemented Interfaces:
FlowableSubscriber<U>
,Disposable
,org.reactivestreams.Subscriber<U>
- Enclosing class:
FlowableDebounce.DebounceSubscriber<T,
U>
static final class FlowableDebounce.DebounceSubscriber.DebounceInnerSubscriber<T,U>
extends DisposableSubscriber<U>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final long
(package private) final AtomicBoolean
(package private) final FlowableDebounce.DebounceSubscriber
<T, U> (package private) final T
-
Constructor Summary
ConstructorsConstructorDescriptionDebounceInnerSubscriber
(FlowableDebounce.DebounceSubscriber<T, U> parent, long index, T value) -
Method Summary
Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request
-
Field Details
-
parent
-
index
final long index -
value
-
done
boolean done -
once
-
-
Constructor Details
-
DebounceInnerSubscriber
DebounceInnerSubscriber(FlowableDebounce.DebounceSubscriber<T, U> parent, long index, T value)
-
-
Method Details
-
onNext
-
emit
void emit() -
onError
-
onComplete
public void onComplete()
-