Uses of Class
io.reactivex.rxjava3.processors.MulticastProcessor
-
Packages that use MulticastProcessor 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 MulticastProcessor in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as MulticastProcessor Modifier and Type Field Description (package private) MulticastProcessor<T>
MulticastProcessor.MulticastSubscription. parent
Methods in io.reactivex.rxjava3.processors that return MulticastProcessor Modifier and Type Method Description static <T> @NonNull MulticastProcessor<T>
MulticastProcessor. create()
Constructs a fresh instance with the default Flowable.bufferSize() prefetch amount and no refCount-behavior.static <T> @NonNull MulticastProcessor<T>
MulticastProcessor. create(boolean refCount)
Constructs a fresh instance with the default Flowable.bufferSize() prefetch amount and the optional refCount-behavior.static <T> @NonNull MulticastProcessor<T>
MulticastProcessor. create(int bufferSize)
Constructs a fresh instance with the given prefetch amount and no refCount behavior.static <T> @NonNull MulticastProcessor<T>
MulticastProcessor. create(int bufferSize, boolean refCount)
Constructs a fresh instance with the given prefetch amount and the optional refCount-behavior.Constructors in io.reactivex.rxjava3.processors with parameters of type MulticastProcessor Constructor Description MulticastSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, MulticastProcessor<@NonNull T> parent)
-