Uses of Class
io.reactivex.rxjava3.processors.BehaviorProcessor
-
Packages that use BehaviorProcessor 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 in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as BehaviorProcessor Modifier and Type Field Description (package private) BehaviorProcessor<T>
BehaviorProcessor.BehaviorSubscription. state
Methods in io.reactivex.rxjava3.processors that return BehaviorProcessor Modifier and Type Method Description static <T> @NonNull BehaviorProcessor<T>
BehaviorProcessor. create()
Creates aBehaviorProcessor
without a default item.static <@NonNull T>
@NonNull BehaviorProcessor<T>BehaviorProcessor. createDefault(@NonNull T defaultValue)
Creates aBehaviorProcessor
that emits the last item it observed and all subsequent items to eachSubscriber
that subscribes to it.Constructors in io.reactivex.rxjava3.processors with parameters of type BehaviorProcessor Constructor Description BehaviorSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, BehaviorProcessor<@NonNull T> state)
-