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>
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 the
other
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
ConstructorsConstructorDescriptionOperatorTimeoutWithSelector
(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 Details
-
OperatorTimeoutWithSelector
public OperatorTimeoutWithSelector(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T, ? extends Observable<V>> timeoutSelector, Observable<? extends T> other)
-