Uses of Class
io.reactivex.rxjava3.processors.MulticastProcessor.MulticastSubscription
Packages that use MulticastProcessor.MulticastSubscription
Package
Description
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 MulticastProcessor.MulticastSubscription in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as MulticastProcessor.MulticastSubscriptionModifier and TypeFieldDescription(package private) static final MulticastProcessor.MulticastSubscription[]
MulticastProcessor.EMPTY
(package private) static final MulticastProcessor.MulticastSubscription[]
MulticastProcessor.TERMINATED
Methods in io.reactivex.rxjava3.processors with parameters of type MulticastProcessor.MulticastSubscriptionModifier and TypeMethodDescription(package private) boolean
MulticastProcessor.add
(MulticastProcessor.MulticastSubscription<@NonNull T> inner) (package private) void
MulticastProcessor.remove
(MulticastProcessor.MulticastSubscription<@NonNull T> inner)