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

Packages that use PublishProcessor.PublishSubscription

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.PublishSubscription in io.reactivex.rxjava3.processors

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

Modifier and Type	Field	Description
(package private) static PublishProcessor.PublishSubscription[]	PublishProcessor.EMPTY	An empty subscribers array to avoid allocating it all the time.
(package private) static PublishProcessor.PublishSubscription[]	PublishProcessor.TERMINATED	The terminated indicator for the subscribers array.

Methods in io.reactivex.rxjava3.processors with parameters of type PublishProcessor.PublishSubscription

Modifier and Type	Method	Description
(package private) boolean	PublishProcessor.add(PublishProcessor.PublishSubscription<@NonNull T> ps)	Tries to add the given subscriber to the subscribers array atomically or returns false if this processor has terminated.
(package private) void	PublishProcessor.remove(PublishProcessor.PublishSubscription<@NonNull T> ps)	Atomically removes the given subscriber if it is subscribed to this processor.