Package rx.internal.operators

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OperatorObserveOn.ObserveOnSubscriber<T>	Observe through individual queue per observer.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	bufferSize
private final boolean	delayError
private final Scheduler	scheduler

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Subscriber<? super T>	call(Subscriber<? super T> child)
static <T> Observable.Operator<T,T>	rebatch(int n)

Methods inherited from class java.lang.Object

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

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

call

public Subscriber<? super T> call(Subscriber<? super T> child)

Specified by:

call in interface Func1<Subscriber<? super T>,Subscriber<? super T>>

rebatch

public static <T> Observable.Operator<T,T> rebatch(int n)