Package rx.internal.operators
Class OperatorTimeoutBase<T>
java.lang.Object
rx.internal.operators.OperatorTimeoutBase<T>
- All Implemented Interfaces:
Func1<Subscriber<? super T>,
,Subscriber<? super T>> Function
,Observable.Operator<T,
T>
- Direct Known Subclasses:
OperatorTimeout
,OperatorTimeoutWithSelector
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static interface
Set up the timeout action on the first value.(package private) static interface
Set up the timeout action based on every value(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final OperatorTimeoutBase.FirstTimeoutStub
<T> (package private) final Observable
<? extends T> (package private) final Scheduler
(package private) final OperatorTimeoutBase.TimeoutStub
<T> -
Constructor Summary
ConstructorsConstructorDescriptionOperatorTimeoutBase
(OperatorTimeoutBase.FirstTimeoutStub<T> firstTimeoutStub, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, Observable<? extends T> other, Scheduler scheduler) -
Method Summary
-
Field Details
-
firstTimeoutStub
-
timeoutStub
-
other
-
scheduler
-
-
Constructor Details
-
OperatorTimeoutBase
OperatorTimeoutBase(OperatorTimeoutBase.FirstTimeoutStub<T> firstTimeoutStub, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, Observable<? extends T> other, Scheduler scheduler)
-
-
Method Details
-
call
- Specified by:
call
in interfaceFunc1<Subscriber<? super T>,
Subscriber<? super T>>
-