Package rx.internal.operators
Class OperatorDebounceWithTime<T>
java.lang.Object
rx.internal.operators.OperatorDebounceWithTime<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Func1<Subscriber<? super T>,
,Subscriber<? super T>> Function
,Observable.Operator<T,
T>
This operation filters out events which are published too quickly in succession. This is done by dropping events which are
followed up by other events before a specified timer has expired. If the timer expires and no follow up event was published (yet)
the last received event is published.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
Tracks the last value to be emitted and manages completion. -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
timeout
final long timeout -
unit
-
scheduler
-
-
Constructor Details
-
OperatorDebounceWithTime
- Parameters:
timeout
- How long each event has to be the 'last event' before it gets published.unit
- The unit of time for the specified timeout.scheduler
- TheScheduler
to use internally to manage the timers which handle timeout for each event.
-
-
Method Details
-
call
- Specified by:
call
in interfaceFunc1<Subscriber<? super T>,
Subscriber<? super T>>
-