OperatorTimeout

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

All Implemented Interfaces:

Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>
```
public final class OperatorTimeout<T>
extends Object
```
Applies a timeout policy for each element in the observable sequence, using the specified scheduler to run timeout timers. If the next element isn't received within the specified timeout duration starting from its predecessor, the other observable sequence is used to produce future messages from that point on.

Constructor Summary

Constructors

Constructor and Description
`OperatorTimeout(long timeout, TimeUnit timeUnit, Observable<? extends T> other, 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

OperatorTimeout

public OperatorTimeout(long timeout,
                       TimeUnit timeUnit,
                       Observable<? extends T> other,
                       Scheduler scheduler)

Method Detail

call

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

Class OperatorTimeout<T>

Constructor Summary

Constructors

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

OperatorTimeout

Method Detail

call