Uses of Class
io.reactivex.rxjava3.processors.ReplayProcessor.ReplaySubscription

Packages that use ReplayProcessor.ReplaySubscription

Package	Description
io.reactivex.rxjava3.processors	Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.

Uses of ReplayProcessor.ReplaySubscription in io.reactivex.rxjava3.processors

Fields in io.reactivex.rxjava3.processors declared as ReplayProcessor.ReplaySubscription

Modifier and Type	Field	Description
(package private) static final ReplayProcessor.ReplaySubscription[]	ReplayProcessor.EMPTY
(package private) static final ReplayProcessor.ReplaySubscription[]	ReplayProcessor.TERMINATED

Methods in io.reactivex.rxjava3.processors with parameters of type ReplayProcessor.ReplaySubscription

Modifier and Type	Method	Description
(package private) boolean	ReplayProcessor.add(ReplayProcessor.ReplaySubscription<@NonNull T> rs)
(package private) void	ReplayProcessor.remove(ReplayProcessor.ReplaySubscription<@NonNull T> rs)
void	ReplayProcessor.ReplayBuffer.replay(ReplayProcessor.ReplaySubscription<@NonNull T> rs)
void	ReplayProcessor.SizeAndTimeBoundReplayBuffer.replay(ReplayProcessor.ReplaySubscription<T> rs)
void	ReplayProcessor.SizeBoundReplayBuffer.replay(ReplayProcessor.ReplaySubscription<@NonNull T> rs)
void	ReplayProcessor.UnboundedReplayBuffer.replay(ReplayProcessor.ReplaySubscription<T> rs)