com.github.davidmoten.rx.internal.operators

Class OperatorWindowMinMax<T>

java.lang.Object

com.github.davidmoten.rx.internal.operators.OperatorWindowMinMax<T>

Type Parameters:

T - generic type of stream emissions

All Implemented Interfaces:

rx.functions.Func1<rx.Subscriber<? super T>,rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.Operator<T,T>

public final class OperatorWindowMinMax<T>
extends Object
implements rx.Observable.Operator<T,T>

Uses a double-ended queue and collapses entries when they are redundant (whenever a value is added to the queue all values at the end of the queue that are greater or equal to that value are removed).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OperatorWindowMinMax.Metric

Constructor Summary

Constructors

Constructor and Description
OperatorWindowMinMax(int windowSize, Comparator<? super T> comparator, OperatorWindowMinMax.Metric metric)

Method Summary

Modifier and Type	Method and Description
rx.Subscriber<? super T>	call(rx.Subscriber<? super T> child)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorWindowMinMax

public OperatorWindowMinMax(int windowSize,
                            Comparator<? super T> comparator,
                            OperatorWindowMinMax.Metric metric)

Method Detail

call

public rx.Subscriber<? super T> call(rx.Subscriber<? super T> child)

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super T>,rx.Subscriber<? super T>>