Package 

Class OperatorObserveOn

  • All Implemented Interfaces:
    com.tds.common.reactor.Observable.Operator , com.tds.common.reactor.functions.Func1 , com.tds.common.reactor.functions.Function 
    
public final class OperatorObserveOn<T>
 implements Observable.Operator<T, T>

    Delivers events on the specified {@code Scheduler} asynchronously via an unbounded buffer.

    • Method Summary

      Modifier and Type Method Description
      Subscriber<out Object> call(Subscriber<out Object> child)

      • Methods inherited from class com.tds.common.reactor.functions.Func1

        call

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • OperatorObserveOn

        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

        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 {@code RxRingBuffer.MAX} if <= 0