OperatorThrottleFirst

rx.internal.operators

Class OperatorThrottleFirst<T>

java.lang.Object
- rx.internal.operators.OperatorThrottleFirst<T>

All Implemented Interfaces:

Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>
```
public final class OperatorThrottleFirst<T>
extends Object
implements Observable.Operator<T,T>
```
Throttle by windowing a stream and returning the first value in each window.

Constructor Summary

Constructors

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

Method Summary

All Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`Subscriber<? super T>`	`call(Subscriber<? super T> subscriber)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperatorThrottleFirst

public OperatorThrottleFirst(long windowDuration,
                             TimeUnit unit,
                             Scheduler scheduler)

Method Detail

call

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