Uses of Class
rx.internal.operators.OperatorMerge.InnerSubscriber

Packages that use OperatorMerge.InnerSubscriber

Package	Description
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.

Uses of OperatorMerge.InnerSubscriber in rx.internal.operators

Fields in rx.internal.operators declared as OperatorMerge.InnerSubscriber

Modifier and Type	Field	Description
(package private) static final OperatorMerge.InnerSubscriber<?>[]	OperatorMerge.MergeSubscriber.EMPTY	An empty array to avoid creating new empty arrays in removeInner.
(package private) OperatorMerge.InnerSubscriber<?>[]	OperatorMerge.MergeSubscriber.innerSubscribers	Copy-on-write array, guarded by innerGuard.

Methods in rx.internal.operators with parameters of type OperatorMerge.InnerSubscriber

Modifier and Type	Method	Description
(package private) void	OperatorMerge.MergeSubscriber.addInner(OperatorMerge.InnerSubscriber<T> inner)
protected void	OperatorMerge.MergeSubscriber.emitScalar(OperatorMerge.InnerSubscriber<T> subscriber, T value, long r)
protected void	OperatorMerge.MergeSubscriber.queueScalar(OperatorMerge.InnerSubscriber<T> subscriber, T value)
(package private) void	OperatorMerge.MergeSubscriber.removeInner(OperatorMerge.InnerSubscriber<T> inner)
(package private) void	OperatorMerge.MergeSubscriber.tryEmit(OperatorMerge.InnerSubscriber<T> subscriber, T value)	Tries to emit the value directly to the child if no concurrent emission is happening at the moment.