Uses of Class
io.reactivex.rxjava3.processors.AsyncProcessor.AsyncSubscription
Packages that use AsyncProcessor.AsyncSubscription
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 AsyncProcessor.AsyncSubscription in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as AsyncProcessor.AsyncSubscriptionModifier and TypeFieldDescription(package private) static final AsyncProcessor.AsyncSubscription[]
AsyncProcessor.EMPTY
(package private) static final AsyncProcessor.AsyncSubscription[]
AsyncProcessor.TERMINATED
Methods in io.reactivex.rxjava3.processors with parameters of type AsyncProcessor.AsyncSubscriptionModifier and TypeMethodDescription(package private) boolean
AsyncProcessor.add
(AsyncProcessor.AsyncSubscription<@NonNull T> ps) Tries to add the given subscriber to the subscribers array atomically or returns false if the processor has terminated.(package private) void
AsyncProcessor.remove
(AsyncProcessor.AsyncSubscription<@NonNull T> ps) Atomically removes the given subscriber if it is subscribed to this processor.