Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.ReplaySubscriber
-
Packages that use FlowableReplay.ReplaySubscriber Package Description io.reactivex.rxjava3.internal.operators.flowable -
-
Uses of FlowableReplay.ReplaySubscriber in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.ReplaySubscriber Modifier and Type Field Description (package private) FlowableReplay.ReplaySubscriber<T>
FlowableReplay.InnerSubscription. parent
The parent subscriber-to-source used to allow removing the child in case of child cancellation.Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type FlowableReplay.ReplaySubscriber Modifier and Type Field Description private java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>>
FlowableReplay.ReplayPublisher. curr
(package private) java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>>
FlowableReplay. current
Holds the current subscriber that is, will be or just was subscribed to the source observable.(package private) java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>>
FlowableReplay.ReplaySubscriber. current
The current connection.Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.ReplaySubscriber Constructor Description InnerSubscription(FlowableReplay.ReplaySubscriber<T> parent, org.reactivestreams.Subscriber<? super T> child)
Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableReplay.ReplaySubscriber Constructor Description FlowableReplay(org.reactivestreams.Publisher<T> onSubscribe, Flowable<T> source, java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> current, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
ReplayPublisher(java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> curr, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
ReplaySubscriber(FlowableReplay.ReplayBuffer<T> buffer, java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> current)
-