Uses of Class
io.reactivex.rxjava3.processors.MulticastProcessor.MulticastSubscription
-
Packages that use MulticastProcessor.MulticastSubscription Package Description io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessorclass, the Reactive StreamsProcessorinterface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher. -
-
Uses of MulticastProcessor.MulticastSubscription in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as MulticastProcessor.MulticastSubscription Modifier and Type Field Description (package private) static MulticastProcessor.MulticastSubscription[]MulticastProcessor. EMPTY(package private) static MulticastProcessor.MulticastSubscription[]MulticastProcessor. TERMINATEDMethods in io.reactivex.rxjava3.processors with parameters of type MulticastProcessor.MulticastSubscription Modifier and Type Method Description (package private) booleanMulticastProcessor. add(MulticastProcessor.MulticastSubscription<@NonNull T> inner)(package private) voidMulticastProcessor. remove(MulticastProcessor.MulticastSubscription<@NonNull T> inner)
-