hu.akarnokd.rxjava2.internal.operators.nbp

Class NbpOperatorWindow<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

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

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

NbpOperatorWindow

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

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