Uses of Class
io.reactivex.rxjava3.subjects.UnicastSubject
Packages that use UnicastSubject
Package
Description
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
-
Uses of UnicastSubject in io.reactivex.rxjava3.subjects
Methods in io.reactivex.rxjava3.subjects that return UnicastSubjectModifier and TypeMethodDescriptionstatic <T> @NonNull UnicastSubject<T> UnicastSubject.create()Creates an UnicastSubject with an internal buffer capacity hint 16.static <T> @NonNull UnicastSubject<T> UnicastSubject.create(boolean delayError) Creates an UnicastSubject with an internal buffer capacity hint 16 and given delay error flag.static <T> @NonNull UnicastSubject<T> UnicastSubject.create(int capacityHint) Creates an UnicastSubject with the given internal buffer capacity hint.static <T> @NonNull UnicastSubject<T> Creates an UnicastSubject with the given internal buffer capacity hint and a callback for the case when the single Subscriber cancels its subscription or the subject is terminated.static <T> @NonNull UnicastSubject<T> Creates an UnicastSubject with the given internal buffer capacity hint, delay error flag and a callback for the case when the single Observer disposes itsDisposableor the subject is terminated.