Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.ReplaySubscriber
Packages that use FlowableReplay.ReplaySubscriber
-
Uses of FlowableReplay.ReplaySubscriber in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.ReplaySubscriberModifier and TypeFieldDescription(package private) final 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.ReplaySubscriberModifier and TypeFieldDescriptionprivate final AtomicReference
<FlowableReplay.ReplaySubscriber<T>> FlowableReplay.ReplayPublisher.curr
(package private) final AtomicReference
<FlowableReplay.ReplaySubscriber<T>> FlowableReplay.current
Holds the current subscriber that is, will be or just was subscribed to the source observable.(package private) final AtomicReference
<FlowableReplay.ReplaySubscriber<T>> FlowableReplay.ReplaySubscriber.current
The current connection.Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.ReplaySubscriberModifierConstructorDescription(package private)
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.ReplaySubscriberModifierConstructorDescriptionprivate
FlowableReplay
(org.reactivestreams.Publisher<T> onSubscribe, Flowable<T> source, AtomicReference<FlowableReplay.ReplaySubscriber<T>> current, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory) (package private)
ReplayPublisher
(AtomicReference<FlowableReplay.ReplaySubscriber<T>> curr, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory) (package private)
ReplaySubscriber
(FlowableReplay.ReplayBuffer<T> buffer, AtomicReference<FlowableReplay.ReplaySubscriber<T>> current)