hu.akarnokd.rxjava2.internal.operators

Class OperatorObserveOn<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.OperatorObserveOn<T>

All Implemented Interfaces:

Function<org.reactivestreams.Subscriber<? super T>,org.reactivestreams.Subscriber<? super T>>, Observable.Operator<T,T>

public final class OperatorObserveOn<T>
extends java.lang.Object
implements Observable.Operator<T,T>

Constructor Summary

Constructors

Constructor and Description
OperatorObserveOn(Scheduler scheduler, boolean delayError, int bufferSize)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Subscriber<? super T>	apply(org.reactivestreams.Subscriber<? super T> t)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorObserveOn

public OperatorObserveOn(Scheduler scheduler,
                         boolean delayError,
                         int bufferSize)

Method Detail

apply

public org.reactivestreams.Subscriber<? super T> apply(org.reactivestreams.Subscriber<? super T> t)

Specified by:

apply in interface Function<org.reactivestreams.Subscriber<? super T>,org.reactivestreams.Subscriber<? super T>>