Package rx.internal.operators
Class OperatorDebounceWithTime.DebounceState<T>
- java.lang.Object
-
- rx.internal.operators.OperatorDebounceWithTime.DebounceState<T>
-
- Type Parameters:
T
- the value type
- Enclosing class:
- OperatorDebounceWithTime<T>
static final class OperatorDebounceWithTime.DebounceState<T> extends java.lang.Object
Tracks the last value to be emitted and manages completion.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
emitting
Guarded by this.(package private) boolean
hasValue
Guarded by this.(package private) int
index
Guarded by this.(package private) boolean
terminate
Guarded by this.(package private) T
value
Guarded by this.
-
Constructor Summary
Constructors Constructor Description DebounceState()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clear()
void
emit(int index, Subscriber<T> onNextAndComplete, Subscriber<?> onError)
void
emitAndComplete(Subscriber<T> onNextAndComplete, Subscriber<?> onError)
int
next(T value)
-
-
-
Field Detail
-
index
int index
Guarded by this.
-
value
T value
Guarded by this.
-
hasValue
boolean hasValue
Guarded by this.
-
terminate
boolean terminate
Guarded by this.
-
emitting
boolean emitting
Guarded by this.
-
-
Method Detail
-
next
public int next(T value)
-
emit
public void emit(int index, Subscriber<T> onNextAndComplete, Subscriber<?> onError)
-
emitAndComplete
public void emitAndComplete(Subscriber<T> onNextAndComplete, Subscriber<?> onError)
-
clear
public void clear()
-
-