Uses of Class
io.reactivex.rxjava3.processors.BehaviorProcessor.BehaviorSubscription
-
Packages that use BehaviorProcessor.BehaviorSubscription 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 BehaviorProcessor.BehaviorSubscription in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as BehaviorProcessor.BehaviorSubscription Modifier and Type Field Description (package private) static BehaviorProcessor.BehaviorSubscription[]
BehaviorProcessor. EMPTY
(package private) static BehaviorProcessor.BehaviorSubscription[]
BehaviorProcessor. TERMINATED
Methods in io.reactivex.rxjava3.processors that return BehaviorProcessor.BehaviorSubscription Modifier and Type Method Description (package private) BehaviorProcessor.BehaviorSubscription<T>[]
BehaviorProcessor. terminate(java.lang.Object terminalValue)
Methods in io.reactivex.rxjava3.processors with parameters of type BehaviorProcessor.BehaviorSubscription Modifier and Type Method Description (package private) boolean
BehaviorProcessor. add(BehaviorProcessor.BehaviorSubscription<@NonNull T> rs)
(package private) void
BehaviorProcessor. remove(BehaviorProcessor.BehaviorSubscription<@NonNull T> rs)
-