Uses of Class
io.reactivex.rxjava3.subjects.UnicastSubject
-
Packages that use UnicastSubject Package Description io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.subjects 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.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as UnicastSubject Modifier and Type Field Description (package private) UnicastSubject<T>ObservableWindow.WindowExactObserver. window(package private) UnicastSubject<T>ObservableWindowBoundary.WindowBoundaryMainObserver. window(package private) UnicastSubject<T>ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept. window(package private) UnicastSubject<T>ObservableWindowTimed.WindowExactBoundedObserver. window(package private) UnicastSubject<T>ObservableWindowTimed.WindowExactUnboundedObserver. windowFields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type UnicastSubject Modifier and Type Field Description (package private) java.util.Map<java.lang.Integer,UnicastSubject<TRight>>ObservableGroupJoin.GroupJoinDisposable. lefts(package private) java.util.ArrayDeque<UnicastSubject<T>>ObservableWindow.WindowSkipObserver. windows(package private) java.util.List<UnicastSubject<T>>ObservableWindowBoundarySelector.WindowBoundaryMainObserver. windows(package private) java.util.List<UnicastSubject<T>>ObservableWindowTimed.WindowSkipObserver. windowsMethods in io.reactivex.rxjava3.internal.operators.observable that return UnicastSubject Modifier and Type Method Description (package private) UnicastSubject<T>ObservableWindowTimed.WindowExactBoundedObserver. createNewWindow(UnicastSubject<T> window)Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type UnicastSubject Modifier and Type Method Description (package private) UnicastSubject<T>ObservableWindowTimed.WindowExactBoundedObserver. createNewWindow(UnicastSubject<T> window)Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type UnicastSubject Constructor Description WindowEndObserverIntercept(ObservableWindowBoundarySelector.WindowBoundaryMainObserver<T,?,V> parent, UnicastSubject<T> window) -
Uses of UnicastSubject in io.reactivex.rxjava3.subjects
Methods in io.reactivex.rxjava3.subjects that return UnicastSubject Modifier and Type Method Description static <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>UnicastSubject. create(int capacityHint, @NonNull java.lang.Runnable onTerminate)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>UnicastSubject. create(int capacityHint, @NonNull java.lang.Runnable onTerminate, boolean delayError)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.
-