Package rx.internal.operators
Class OperatorTimeoutWithSelector<T,U,V>
- java.lang.Object
-
- rx.internal.operators.OperatorTimeoutBase<T>
-
- rx.internal.operators.OperatorTimeoutWithSelector<T,U,V>
-
- Type Parameters:
T
- the value type of the main ObservableU
- the value type of the first timeout ObservableV
- the value type of the subsequent timeout Observable
- All Implemented Interfaces:
Func1<Subscriber<? super T>,Subscriber<? super T>>
,Function
,Observable.Operator<T,T>
public class OperatorTimeoutWithSelector<T,U,V> extends OperatorTimeoutBase<T>
Returns an Observable that mirrors the source Observable. If either the first item emitted by the source Observable or any subsequent item don't arrive within time windows defined by provided Observables, switch to theother
Observable if provided, or emit a TimeoutException .
-
-
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
Constructors Constructor Description OperatorTimeoutWithSelector(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other)
-
Method Summary
-
Methods inherited from class rx.internal.operators.OperatorTimeoutBase
call
-
-
-
-
Constructor Detail
-
OperatorTimeoutWithSelector
public OperatorTimeoutWithSelector(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other)
-
-