Uses of Class
io.reactivex.rxjava3.processors.PublishProcessor
-
Packages that use PublishProcessor 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 in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as PublishProcessor Modifier and Type Field Description (package private) PublishProcessor<T>
PublishProcessor.PublishSubscription. parent
The parent processor servicing this subscriber.Methods in io.reactivex.rxjava3.processors that return PublishProcessor Modifier and Type Method Description static <T> @NonNull PublishProcessor<T>
PublishProcessor. create()
Constructs a PublishProcessor.Constructors in io.reactivex.rxjava3.processors with parameters of type PublishProcessor Constructor Description PublishSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, PublishProcessor<@NonNull T> parent)
Constructs a PublishSubscriber, wraps the actual subscriber and the state.
-