Package rx.internal.operators
Class OperatorTimeout<T>
java.lang.Object
rx.internal.operators.OperatorTimeoutBase<T>
rx.internal.operators.OperatorTimeout<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Func1<Subscriber<? super T>,
,Subscriber<? super T>> Function
,Observable.Operator<T,
T>
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.
-
Nested Class Summary
Nested classes/interfaces inherited from class rx.internal.operators.OperatorTimeoutBase
OperatorTimeoutBase.FirstTimeoutStub<T>, OperatorTimeoutBase.TimeoutStub<T>, OperatorTimeoutBase.TimeoutSubscriber<T>
-
Field Summary
Fields inherited from class rx.internal.operators.OperatorTimeoutBase
firstTimeoutStub, other, scheduler, timeoutStub
-
Constructor Summary
ConstructorsConstructorDescriptionOperatorTimeout
(long timeout, TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler) -
Method Summary
Methods inherited from class rx.internal.operators.OperatorTimeoutBase
call
-
Constructor Details
-
OperatorTimeout
public OperatorTimeout(long timeout, TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler)
-