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