Uses of Class
io.reactivex.rxjava3.processors.PublishProcessor.PublishSubscription
Packages that use PublishProcessor.PublishSubscription
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 PublishProcessor.PublishSubscription in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as PublishProcessor.PublishSubscriptionModifier and TypeFieldDescription(package private) static final PublishProcessor.PublishSubscription[]
PublishProcessor.EMPTY
An empty subscribers array to avoid allocating it all the time.(package private) static final PublishProcessor.PublishSubscription[]
PublishProcessor.TERMINATED
The terminated indicator for the subscribers array.Methods in io.reactivex.rxjava3.processors with parameters of type PublishProcessor.PublishSubscriptionModifier and TypeMethodDescription(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.