com.github.davidmoten.rx.internal.operators

Class OperatorSampleFirst<T>

java.lang.Object

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

Type Parameters:

T - the value type

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 OperatorSampleFirst<T>
extends Object
implements rx.Observable.Operator<T,T>

Throttle by windowing a stream and returning the first value in each window.

Constructor Summary

Constructors

Constructor and Description
OperatorSampleFirst(long windowDurationMs, TimeUnit unit, rx.Scheduler scheduler)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorSampleFirst

public OperatorSampleFirst(long windowDurationMs,
                           TimeUnit unit,
                           rx.Scheduler scheduler)

Method Detail

call

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

Specified by:

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