Uses of Class
rx.internal.operators.OperatorReplay.ReplaySubscriber
-
Packages that use OperatorReplay.ReplaySubscriber 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 OperatorReplay.ReplaySubscriber in rx.internal.operators
Fields in rx.internal.operators declared as OperatorReplay.ReplaySubscriber Modifier and Type Field Description (package private) 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.ReplaySubscriber Modifier and Type Field Description (package private) java.util.concurrent.atomic.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.ReplaySubscriber Constructor Description InnerProducer(OperatorReplay.ReplaySubscriber<T> parent, Subscriber<? super T> child)
Constructor parameters in rx.internal.operators with type arguments of type OperatorReplay.ReplaySubscriber Constructor Description OperatorReplay(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, java.util.concurrent.atomic.AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory)
-