Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.InnerSubscription
Packages that use FlowableReplay.InnerSubscription
-
Uses of FlowableReplay.InnerSubscription in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.InnerSubscriptionModifier and TypeFieldDescription(package private) static final FlowableReplay.InnerSubscription[]
FlowableReplay.ReplaySubscriber.EMPTY
Indicates an empty array of inner subscriptions.(package private) static final FlowableReplay.InnerSubscription[]
FlowableReplay.ReplaySubscriber.TERMINATED
Indicates a terminated ReplaySubscriber.Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.InnerSubscriptionModifier and TypeMethodDescription(package private) boolean
FlowableReplay.ReplaySubscriber.add
(FlowableReplay.InnerSubscription<T> producer) Atomically try adding a new InnerSubscription to this Subscriber or return false if this Subscriber was terminated.(package private) void
FlowableReplay.ReplaySubscriber.remove
(FlowableReplay.InnerSubscription<T> p) Atomically removes the given InnerSubscription from the subscribers array.final void
FlowableReplay.BoundedReplayBuffer.replay
(FlowableReplay.InnerSubscription<T> output) void
FlowableReplay.ReplayBuffer.replay
(FlowableReplay.InnerSubscription<T> output) Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.void
FlowableReplay.UnboundedReplayBuffer.replay
(FlowableReplay.InnerSubscription<T> output)