hu.akarnokd.rxjava2.internal.operators

Class OperatorWindow<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
OperatorWindow(long count, long skip, int capacityHint)

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

OperatorWindow

public OperatorWindow(long count,
                      long skip,
                      int capacityHint)

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