hu.akarnokd.rxjava2.internal.operators

Class OperatorWindowTimed<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
OperatorWindowTimed(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
org.reactivestreams.Subscriber<? super T>	apply(org.reactivestreams.Subscriber<? super Observable<T>> t)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorWindowTimed

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

Method Detail

apply

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

Specified by:

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