Uses of Class
rx.internal.operators.OperatorMerge.InnerSubscriber
Packages that use OperatorMerge.InnerSubscriber
Package
Description
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.InnerSubscriberModifier and TypeFieldDescription(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.InnerSubscriberModifier and TypeMethodDescription(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.