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. window
Fields 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. windows
Methods 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 itsDisposable
or the subject is terminated.
-