Modifier and Type	Class and Description
pack-priv static class	OperatorSwitch.Holder Lazy initialization via inner-class holder.
pack-priv static class	OperatorSwitch.HolderDelayError Lazy initialization via inner-class holder.
pack-priv static class	OperatorSwitch.InnerSubscriber<T>
pack-priv static class	OperatorSwitch.SwitchSubscriber<T>

Modifier and Type	Field and Description
pack-priv final boolean	delayError

Access	Constructor and Description
pack-priv	OperatorSwitch(boolean delayError)

Modifier and Type	Method and Description
public Subscriber<? super Observable<? extends T>>	call(final Subscriber<? super T> child) Implements rx.functions.Func1.call.
public static < the value type T> OperatorSwitch<T>	Returns: a singleton instance of this stateless operator. instance(boolean should the errors of the inner sources delayed until the main sequence completes? delayError) Returns a singleton instance of the operator based on the delayError parameter.

delayError	back to summary
pack-priv final boolean delayError

OperatorSwitch	back to summary
pack-priv OperatorSwitch(boolean delayError)

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

instance	back to summary
public static <T> OperatorSwitch<T> instance(boolean delayError) Returns a singleton instance of the operator based on the delayError parameter. Parameters <T> the value type delayError:boolean should the errors of the inner sources delayed until the main sequence completes? Returns:OperatorSwitch<T> a singleton instance of this stateless operator. Annotations @SuppressWarnings:unchecked

pack-priv final Class OperatorSwitch.Holder

Class Inheritance

extends Object

java.lang.Object
rx.internal.operators.OperatorSwitch.Holder

Lazy initialization via inner-class holder.

Field Summary

Modifier and Type	Field and Description
pack-priv static final OperatorSwitch<Object>	INSTANCE A singleton instance.

Constructor Summary

Access	Constructor and Description
pack-priv	Holder()

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

INSTANCE	back to summary
pack-priv static final OperatorSwitch<Object> INSTANCE A singleton instance.

Constructor Detail

Holder	back to summary
pack-priv Holder()

rx.internal.operators back to summary

pack-priv final Class OperatorSwitch.HolderDelayError

Class Inheritance

extends Object

java.lang.Object
rx.internal.operators.OperatorSwitch.HolderDelayError

Lazy initialization via inner-class holder.

Field Summary

Modifier and Type	Field and Description
pack-priv static final OperatorSwitch<Object>	INSTANCE A singleton instance.

Constructor Summary

Access	Constructor and Description
pack-priv	HolderDelayError()

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

INSTANCE	back to summary
pack-priv static final OperatorSwitch<Object> INSTANCE A singleton instance.

Constructor Detail

HolderDelayError	back to summary
pack-priv HolderDelayError()

rx.internal.operators back to summary

pack-priv final Class OperatorSwitch.InnerSubscriber<T>

Class Inheritance

extends Subscriber<T>

java.lang.Object
rx.Subscriber
rx.internal.operators.OperatorSwitch.InnerSubscriber

Field Summary

Modifier and Type	Field and Description
private final long	id
private final OperatorSwitch.SwitchSubscriber<T>	parent

Constructor Summary

Access	Constructor and Description
pack-priv	InnerSubscriber(long id, OperatorSwitch.SwitchSubscriber<T> parent)

Method Summary

Modifier and Type	Method and Description
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(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(T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
public void	setProducer(Producer producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from p) Overrides rx.Subscriber.setProducer. If other subscriber is set (by calling constructor `Subscriber(Subscriber)` or `Subscriber(Subscriber, boolean)`) then this method calls `setProducer` on the other subscriber.

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

Field Detail

id	back to summary
private final long id

parent	back to summary
private final OperatorSwitch.SwitchSubscriber<T> parent

Constructor Detail

InnerSubscriber	back to summary
pack-priv InnerSubscriber(long id, OperatorSwitch.SwitchSubscriber<T> parent)

Method Detail

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(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(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(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(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

setProducer back to summary

setProducer	back to summary
public void setProducer(Producer p) Overrides rx.Subscriber.setProducer. Doc from rx.Subscriber.setProducer. If other subscriber is set (by calling constructor `Subscriber(Subscriber)` or `Subscriber(Subscriber, boolean)`) then this method calls `setProducer` on the other subscriber. If the other subscriber is not set and no requests have been made to this subscriber then `p.request(Long.MAX_VALUE)` is called. If the other subscriber is not set and some requests have been made to this subscriber then `p.request(n)` is called where n is the accumulated requests to this subscriber. Parameters p:Producer producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from Annotations @Override

public void setProducer(Producer p)

Overrides rx.Subscriber.setProducer.

Doc from rx.Subscriber.setProducer.

If other subscriber is set (by calling constructor Subscriber(Subscriber) or Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber. If the other subscriber is not set and no requests have been made to this subscriber then p.request(Long.MAX_VALUE) is called. If the other subscriber is not set and some requests have been made to this subscriber then p.request(n) is called where n is the accumulated requests to this subscriber.

Parameters

p:Producer: producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OperatorSwitch.SwitchSubscriber<T>

Class Inheritance

extends Subscriber<Observable<? extends T>>

java.lang.Object
rx.Subscriber
rx.internal.operators.OperatorSwitch.SwitchSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final Subscriber<? super T>	child
pack-priv final boolean	delayError
pack-priv boolean	emitting
pack-priv Throwable	error
pack-priv final AtomicLong	index
pack-priv boolean	innerActive
pack-priv volatile boolean	mainDone
pack-priv boolean	missed
pack-priv Producer	producer Hides rx.Subscriber.producer.
pack-priv final SpscLinkedArrayQueue<Object>	queue
pack-priv long	requested Hides rx.Subscriber.requested.
pack-priv final SerialSubscription	serial
pack-priv static final Throwable	TERMINAL_ERROR

Constructor Summary

Access	Constructor and Description
pack-priv	SwitchSubscriber(Subscriber<? super T> child, boolean delayError)

Method Summary

Modifier and Type	Method and Description
protected boolean	checkTerminated(boolean localMainDone, boolean localInnerActive, Throwable localError, final SpscLinkedArrayQueue<Object> localQueue, final Subscriber<? super T> localChild, boolean empty)
pack-priv void	childRequested(long n)
pack-priv void	clearProducer()
pack-priv void	complete(long id)
pack-priv void	drain()
pack-priv void	emit(T value, OperatorSwitch.InnerSubscriber<T> inner)
pack-priv void	error(Throwable e, long id)
pack-priv void	init()
pack-priv void	innerProducer(Producer p, long id)
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(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(Observable<? extends T> the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
pack-priv void	pluginError(Throwable e)
pack-priv boolean	updateError(Throwable next)

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

Field Detail

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

delayError	back to summary
pack-priv final boolean delayError

emitting	back to summary
pack-priv boolean emitting

error	back to summary
pack-priv Throwable error

index	back to summary
pack-priv final AtomicLong index

innerActive	back to summary
pack-priv boolean innerActive

mainDone	back to summary
pack-priv volatile boolean mainDone

missed	back to summary
pack-priv boolean missed

producer	back to summary
pack-priv Producer producer Hides rx.Subscriber.producer.

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

requested	back to summary
pack-priv long requested Hides rx.Subscriber.requested.

serial	back to summary
pack-priv final SerialSubscription serial

TERMINAL_ERROR	back to summary
pack-priv static final Throwable TERMINAL_ERROR

Constructor Detail

SwitchSubscriber	back to summary
pack-priv SwitchSubscriber(Subscriber<? super T> child, boolean delayError)

Method Detail

checkTerminated	back to summary
protected boolean checkTerminated(boolean localMainDone, boolean localInnerActive, Throwable localError, final SpscLinkedArrayQueue<Object> localQueue, final Subscriber<? super T> localChild, boolean empty)

childRequested	back to summary
pack-priv void childRequested(long n)

clearProducer	back to summary
pack-priv void clearProducer()

complete	back to summary
pack-priv void complete(long id)

drain	back to summary
pack-priv void drain()

emit	back to summary
pack-priv void emit(T value, OperatorSwitch.InnerSubscriber<T> inner)

error	back to summary
pack-priv void error(Throwable e, long id)

init	back to summary
pack-priv void init()

innerProducer	back to summary
pack-priv void innerProducer(Producer p, long id)

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

onError back to summary

public void onError(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

public void onNext(Observable<? extends 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:Observable<? extends T>: the item emitted by the Observable

Annotations

@Override

pluginError	back to summary
pack-priv void pluginError(Throwable e)

updateError	back to summary
pack-priv boolean updateError(Throwable next)

public final Class OperatorSwitch<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OperatorSwitch.Holder

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

pack-priv final Class OperatorSwitch.HolderDelayError

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

pack-priv final Class OperatorSwitch.InnerSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OperatorSwitch.SwitchSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail