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>
-
-
Constructor Summary
Constructors Constructor Description DebounceInnerSubscriber(FlowableDebounce.DebounceSubscriber<T,U> parent, long index, T value)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
emit()
void
onComplete()
void
onError(java.lang.Throwable t)
void
onNext(U t)
-
Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request
-
-
-
-
Field Detail
-
parent
final FlowableDebounce.DebounceSubscriber<T,U> parent
-
index
final long index
-
value
final T value
-
done
boolean done
-
once
final java.util.concurrent.atomic.AtomicBoolean once
-
-
Constructor Detail
-
DebounceInnerSubscriber
DebounceInnerSubscriber(FlowableDebounce.DebounceSubscriber<T,U> parent, long index, T value)
-
-
Method Detail
-
onNext
public void onNext(U t)
-
emit
void emit()
-
onError
public void onError(java.lang.Throwable t)
-
onComplete
public void onComplete()
-
-