Uses of Class
io.reactivex.rxjava3.processors.PublishProcessor

Packages that use PublishProcessor

Package	Description
io.reactivex.rxjava3.processors	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 PublishProcessor in io.reactivex.rxjava3.processors

Fields in io.reactivex.rxjava3.processors declared as PublishProcessor

Modifier and Type	Field	Description
(package private) PublishProcessor<T>	PublishProcessor.PublishSubscription.parent	The parent processor servicing this subscriber.

Methods in io.reactivex.rxjava3.processors that return PublishProcessor

Modifier and Type	Method	Description
static <T> @NonNull PublishProcessor<T>	PublishProcessor.create()	Constructs a PublishProcessor.

Constructors in io.reactivex.rxjava3.processors with parameters of type PublishProcessor

Constructor	Description
PublishSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, PublishProcessor<@NonNull T> parent)	Constructs a PublishSubscriber, wraps the actual subscriber and the state.