hu.akarnokd.rxjava2.internal.operators.nbp

Class NbpOperatorSampleTimed<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSampleTimed<T>

All Implemented Interfaces:

Function<NbpObservable.NbpSubscriber<? super T>,NbpObservable.NbpSubscriber<? super T>>, NbpObservable.NbpOperator<T,T>

public final class NbpOperatorSampleTimed<T>
extends java.lang.Object
implements NbpObservable.NbpOperator<T,T>

Constructor Summary

Constructors

Constructor and Description
NbpOperatorSampleTimed(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
NbpObservable.NbpSubscriber<? super T>	apply(NbpObservable.NbpSubscriber<? super T> t)

Methods inherited from class java.lang.Object

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

Constructor Detail

NbpOperatorSampleTimed

public NbpOperatorSampleTimed(long period,
                              java.util.concurrent.TimeUnit unit,
                              Scheduler scheduler)

Method Detail

apply

public NbpObservable.NbpSubscriber<? super T> apply(NbpObservable.NbpSubscriber<? super T> t)

Specified by:

apply in interface Function<NbpObservable.NbpSubscriber<? super T>,NbpObservable.NbpSubscriber<? super T>>