rx.internal.operators

Class OperatorDebounceWithTime<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T> 

    public final class OperatorDebounceWithTime<T>
extends Object
implements 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.

    • Constructor Detail

      • OperatorDebounceWithTime

        public 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.