Class OperatorTimeout<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    Func1<Subscriber<? super T>,​Subscriber<? super T>>, Function, Observable.Operator<T,​T>

    public final class OperatorTimeout<T>
    extends OperatorTimeoutBase<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.
    • Constructor Detail

      • OperatorTimeout

        public OperatorTimeout​(long timeout,
                               java.util.concurrent.TimeUnit timeUnit,
                               Observable<? extends T> other,
                               Scheduler scheduler)