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.TERMINATEDMethods in io.reactivex.rxjava3.processors with parameters of type MulticastProcessor.MulticastSubscriptionModifier and TypeMethodDescription(package private) booleanMulticastProcessor.add(MulticastProcessor.MulticastSubscription<@NonNull T> inner) (package private) voidMulticastProcessor.remove(MulticastProcessor.MulticastSubscription<@NonNull T> inner)