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 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 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.
-