public final Class OperatorThrottleFirst<T>

Class Inheritance

extends Object
implements Observable.Operator<T, T>

All Implemented Interfaces

Type Parameters

Imports

java.util.concurrent.TimeUnit, rx.*, .Observable.Operator

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

Field Summary

Modifier and Type	Field and Description
pack-priv final Scheduler	scheduler
pack-priv final long	timeInMilliseconds

Access	Constructor and Description
public	OperatorThrottleFirst(long windowDuration, TimeUnit unit, Scheduler scheduler)

Modifier and Type	Method and Description
public Subscriber<? super T>	call(final Subscriber<? super T> subscriber) Implements rx.functions.Func1.call.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

scheduler	back to summary
pack-priv final Scheduler scheduler

timeInMilliseconds	back to summary
pack-priv final long timeInMilliseconds

OperatorThrottleFirst	back to summary
public OperatorThrottleFirst(long windowDuration, TimeUnit unit, Scheduler scheduler)

call	back to summary
public Subscriber<? super T> call(final Subscriber<? super T> subscriber) Implements rx.functions.Func1.call. Annotations @Override

call

public Subscriber<? super T> call(final Subscriber<? super T> subscriber)

Annotations