hu.akarnokd.rxjava2.internal.operators

Class OperatorDebounceTimed<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.OperatorDebounceTimed<T>

All Implemented Interfaces:

Function<org.reactivestreams.Subscriber<? super T>,org.reactivestreams.Subscriber<? super T>>, Observable.Operator<T,T>

public final class OperatorDebounceTimed<T>
extends java.lang.Object
implements Observable.Operator<T,T>

Constructor Summary

Constructors

Constructor and Description
OperatorDebounceTimed(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Subscriber<? super T>	apply(org.reactivestreams.Subscriber<? super T> t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperatorDebounceTimed

public OperatorDebounceTimed(long timeout,
                             java.util.concurrent.TimeUnit unit,
                             Scheduler scheduler)

Method Detail

apply

public org.reactivestreams.Subscriber<? super T> apply(org.reactivestreams.Subscriber<? super T> t)

Specified by:

apply in interface Function<org.reactivestreams.Subscriber<? super T>,org.reactivestreams.Subscriber<? super T>>