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