Uses of Class
rx.internal.operators.OperatorPublish.PublishSubscriber

Packages that use OperatorPublish.PublishSubscriber

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 OperatorPublish.PublishSubscriber in rx.internal.operators

Fields in rx.internal.operators declared as OperatorPublish.PublishSubscriber

Modifier and Type	Field	Description
(package private) 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.PublishSubscriber

Modifier and Type	Field	Description
(package private) java.util.concurrent.atomic.AtomicReference<OperatorPublish.PublishSubscriber<T>>	OperatorPublish.current	Holds the current subscriber that is, will be or just was subscribed to the source observable.
(package private) java.util.concurrent.atomic.AtomicReference<OperatorPublish.PublishSubscriber<T>>	OperatorPublish.PublishSubscriber.current	Holds onto the current connected PublishSubscriber.

Constructors in rx.internal.operators with parameters of type OperatorPublish.PublishSubscriber

Constructor	Description
InnerProducer(OperatorPublish.PublishSubscriber<T> parent, Subscriber<? super T> child)

Constructor parameters in rx.internal.operators with type arguments of type OperatorPublish.PublishSubscriber

Constructor	Description
OperatorPublish(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, java.util.concurrent.atomic.AtomicReference<OperatorPublish.PublishSubscriber<T>> current)
PublishSubscriber(java.util.concurrent.atomic.AtomicReference<OperatorPublish.PublishSubscriber<T>> current)