hu.akarnokd.rxjava2.internal.operators.nbp

Class NbpOperatorWindowTimed<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
NbpOperatorWindowTimed(long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NbpOperatorWindowTimed

public NbpOperatorWindowTimed(long timespan,
                              long timeskip,
                              java.util.concurrent.TimeUnit unit,
                              Scheduler scheduler,
                              long maxSize,
                              int bufferSize,
                              boolean restartTimerOnMaxSize)

Method Detail

apply

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

Specified by:

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