-
- All Implemented Interfaces:
-
com.tds.common.reactor.Observable.Operator
,com.tds.common.reactor.functions.Func1
,com.tds.common.reactor.functions.Function
public final class OperatorDebounceWithTime<T> implements Observable.Operator<T, T>
-
-
Constructor Summary
Constructors Constructor Description OperatorDebounceWithTime(long timeout, TimeUnit unit, Scheduler scheduler)
-
Method Summary
Modifier and Type Method Description Subscriber<out Object>
call(Subscriber<out Object> child)
-
-
Constructor Detail
-
OperatorDebounceWithTime
OperatorDebounceWithTime(long timeout, TimeUnit unit, Scheduler scheduler)
- 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
- The Scheduler to use internally to manage the timers which handle timeout for each event.
-
-
Method Detail
-
call
Subscriber<out Object> call(Subscriber<out Object> child)
-
-
-
-