Class OperatorObserveOn<T>

java.lang.Object
rx.internal.operators.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 Object implements Observable.Operator<T,T>
Delivers events on the specified Scheduler asynchronously via an unbounded buffer.
  • Field Details

    • scheduler

      private final Scheduler scheduler
    • delayError

      private final boolean delayError
    • bufferSize

      private final int bufferSize
  • Constructor Details

    • 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 invalid input: '<'= 0
  • Method Details