Uses of Class
rx.internal.operators.OperatorPublish.PublishSubscriber
Packages that use OperatorPublish.PublishSubscriber
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of OperatorPublish.PublishSubscriber in rx.internal.operators
Fields in rx.internal.operators declared as OperatorPublish.PublishSubscriberModifier and TypeFieldDescription(package private) final OperatorPublish.PublishSubscriber
<T> OperatorPublish.InnerProducer.parent
The parent subscriber-to-source used to allow removing the child in case of child unsubscription.Fields in rx.internal.operators with type parameters of type OperatorPublish.PublishSubscriberModifier and TypeFieldDescription(package private) final AtomicReference
<OperatorPublish.PublishSubscriber<T>> OperatorPublish.current
Holds the current subscriber that is, will be or just was subscribed to the source observable.(package private) final AtomicReference
<OperatorPublish.PublishSubscriber<T>> OperatorPublish.PublishSubscriber.current
Holds onto the current connected PublishSubscriber.Constructors in rx.internal.operators with parameters of type OperatorPublish.PublishSubscriberModifierConstructorDescriptionInnerProducer
(OperatorPublish.PublishSubscriber<T> parent, Subscriber<? super T> child) Constructor parameters in rx.internal.operators with type arguments of type OperatorPublish.PublishSubscriberModifierConstructorDescriptionprivate
OperatorPublish
(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorPublish.PublishSubscriber<T>> current)