Uses of Class
io.reactivex.rxjava3.processors.AsyncProcessor.AsyncSubscription
-
Packages that use AsyncProcessor.AsyncSubscription 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 AsyncProcessor.AsyncSubscription in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as AsyncProcessor.AsyncSubscription Modifier and Type Field Description (package private) static AsyncProcessor.AsyncSubscription[]
AsyncProcessor. EMPTY
(package private) static AsyncProcessor.AsyncSubscription[]
AsyncProcessor. TERMINATED
Methods in io.reactivex.rxjava3.processors with parameters of type AsyncProcessor.AsyncSubscription Modifier and Type Method Description (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.
-