Modifier and Type	Class and Description
pack-priv static class	OperatorObserveOn.ObserveOnSubscriber<T> Observe through individual queue per observer.

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

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

Modifier and Type	Method and Description
public Subscriber<? super T>	call(Subscriber<? super T> child) Implements rx.functions.Func1.call.
public static <T> Observable.Operator<T, T>	rebatch(final int n)

bufferSize	back to summary
private final int bufferSize

delayError	back to summary
private final boolean delayError

scheduler	back to summary
private final Scheduler scheduler

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

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

call	back to summary
public Subscriber<? super T> call(Subscriber<? super T> child) Implements rx.functions.Func1.call. Annotations @Override

rebatch	back to summary
public static <T> Observable.Operator<T, T> rebatch(final int n)

pack-priv final Class OperatorObserveOn.ObserveOnSubscriber<T>

Class Inheritance

extends Subscriber<T>
implements Action0

java.lang.Object
rx.Subscriber
rx.internal.operators.OperatorObserveOn.ObserveOnSubscriber

All Implemented Interfaces

rx.functions.Action0, rx.functions.Action, rx.functions.Function

Observe through individual queue per observer.

Field Summary

Modifier and Type	Field and Description
pack-priv final Subscriber<? super T>	child
pack-priv final AtomicLong	counter
pack-priv final boolean	delayError
pack-priv long	emitted Remembers how many elements have been emitted before the requests run out.
pack-priv Throwable	error The single exception if not null, should be written before setting finished (release) and read after reading finished (acquire).
pack-priv volatile boolean	finished
pack-priv final int	limit The emission threshold that should trigger a replenishing request.
pack-priv final Queue<Object>	queue
pack-priv final Scheduler.Worker	recursiveScheduler
pack-priv final AtomicLong	requested Hides rx.Subscriber.requested.

Constructor Summary

Access	Constructor and Description
public	ObserveOnSubscriber(Scheduler scheduler, Subscriber<? super T> child, boolean delayError, int bufferSize)

Method Summary

Modifier and Type	Method and Description
public void	call() Implements rx.functions.Action0.call.
pack-priv boolean	checkTerminated(boolean done, boolean isEmpty, Subscriber<? super T> a, Queue<Object> q)
pack-priv void	init()
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(final Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(final T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
protected void	schedule()

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

Field Detail

child	back to summary
pack-priv final Subscriber<? super T> child

counter	back to summary
pack-priv final AtomicLong counter

delayError	back to summary
pack-priv final boolean delayError

emitted	back to summary
pack-priv long emitted Remembers how many elements have been emitted before the requests run out.

error	back to summary
pack-priv Throwable error The single exception if not null, should be written before setting finished (release) and read after reading finished (acquire).

finished	back to summary
pack-priv volatile boolean finished

limit	back to summary
pack-priv final int limit The emission threshold that should trigger a replenishing request.

queue	back to summary
pack-priv final Queue<Object> queue

recursiveScheduler	back to summary
pack-priv final Scheduler.Worker recursiveScheduler

requested	back to summary
pack-priv final AtomicLong requested Hides rx.Subscriber.requested.

Constructor Detail

ObserveOnSubscriber	back to summary
public ObserveOnSubscriber(Scheduler scheduler, Subscriber<? super T> child, boolean delayError, int bufferSize)

Method Detail

call	back to summary
public void call() Implements rx.functions.Action0.call. Annotations @Override

call

back to summary

public void call()

Implements rx.functions.Action0.call.

Annotations

@Override

checkTerminated	back to summary
pack-priv boolean checkTerminated(boolean done, boolean isEmpty, Subscriber<? super T> a, Queue<Object> q)

init	back to summary
pack-priv void init()

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(final Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(final Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(final T t) Implements rx.Observer.onNext. Doc from rx.Observer.onNext. Provides the Observer with a new item to observe. The `Observable` may call this method 0 or more times. The `Observable` will not call this method again after it calls either `onCompleted` or `onError`. Parameters t:T the item emitted by the Observable Annotations @Override

public void onNext(final T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

schedule	back to summary
protected void schedule()

public final Class OperatorObserveOn<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OperatorObserveOn.ObserveOnSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail