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 theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
. -
-
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 ReplayProcessor.ReplaySubscription[]
ReplayProcessor. EMPTY
(package private) static 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)
-