Class OperatorObserveOn<T>

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

    public final class OperatorObserveOn<T>
    extends java.lang.Object
    implements Observable.Operator<T,​T>
    Delivers events on the specified Scheduler asynchronously via an unbounded buffer.
    • Field Detail

      • scheduler

        private final Scheduler scheduler
      • delayError

        private final boolean delayError
      • bufferSize

        private final int bufferSize
    • Constructor Detail

      • OperatorObserveOn

        public OperatorObserveOn​(Scheduler scheduler,
                                 boolean delayError)
        Parameters:
        scheduler - the scheduler to use
        delayError - delay errors until all normal events are emitted in the other thread?
      • OperatorObserveOn

        public OperatorObserveOn​(Scheduler scheduler,
                                 boolean delayError,
                                 int bufferSize)
        Parameters:
        scheduler - the scheduler to use
        delayError - delay errors until all normal events are emitted in the other thread?
        bufferSize - for the buffer feeding the Scheduler workers, defaults to RxRingBuffer.MAX if <= 0