Uses of Class
rx.internal.operators.OperatorReplay.ReplaySubscriber
Packages that use OperatorReplay.ReplaySubscriber
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of OperatorReplay.ReplaySubscriber in rx.internal.operators
Fields in rx.internal.operators declared as OperatorReplay.ReplaySubscriberModifier and TypeFieldDescription(package private) final OperatorReplay.ReplaySubscriber
<T> OperatorReplay.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 OperatorReplay.ReplaySubscriberModifier and TypeFieldDescription(package private) final AtomicReference
<OperatorReplay.ReplaySubscriber<T>> OperatorReplay.current
Holds the current subscriber that is, will be or just was subscribed to the source observable.Constructors in rx.internal.operators with parameters of type OperatorReplay.ReplaySubscriberModifierConstructorDescriptionInnerProducer
(OperatorReplay.ReplaySubscriber<T> parent, Subscriber<? super T> child) Constructor parameters in rx.internal.operators with type arguments of type OperatorReplay.ReplaySubscriberModifierConstructorDescriptionprivate
OperatorReplay
(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory)