-
- 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)
-
-
-
-