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.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as UnicastSubjectModifier and TypeFieldDescription(package private) UnicastSubject
<T> ObservableWindow.WindowExactObserver.window
(package private) UnicastSubject
<T> ObservableWindowBoundary.WindowBoundaryMainObserver.window
(package private) final 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 UnicastSubjectModifier and TypeFieldDescription(package private) final Map
<Integer, UnicastSubject<TRight>> ObservableGroupJoin.GroupJoinDisposable.lefts
(package private) final ArrayDeque
<UnicastSubject<T>> ObservableWindow.WindowSkipObserver.windows
(package private) final List
<UnicastSubject<T>> ObservableWindowBoundarySelector.WindowBoundaryMainObserver.windows
(package private) final List
<UnicastSubject<T>> ObservableWindowTimed.WindowSkipObserver.windows
Methods in io.reactivex.rxjava3.internal.operators.observable that return UnicastSubjectModifier and TypeMethodDescription(package private) UnicastSubject
<T> ObservableWindowTimed.WindowExactBoundedObserver.createNewWindow
(UnicastSubject<T> window) Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type UnicastSubjectModifier and TypeMethodDescription(package private) UnicastSubject
<T> ObservableWindowTimed.WindowExactBoundedObserver.createNewWindow
(UnicastSubject<T> window) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type UnicastSubjectModifierConstructorDescription(package private)
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 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 itsDisposable
or the subject is terminated.