Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.InnerSubscription
-
Packages that use FlowableReplay.InnerSubscription Package Description io.reactivex.rxjava3.internal.operators.flowable -
-
Uses of FlowableReplay.InnerSubscription in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.InnerSubscription Modifier and Type Field Description (package private) static FlowableReplay.InnerSubscription[]
FlowableReplay.ReplaySubscriber. EMPTY
Indicates an empty array of inner subscriptions.(package private) static FlowableReplay.InnerSubscription[]
FlowableReplay.ReplaySubscriber. TERMINATED
Indicates a terminated ReplaySubscriber.Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.InnerSubscription Modifier and Type Method Description (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.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)
-