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) 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 UnicastSubject

Modifier and Type	Field	Description
(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 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

Modifier	Constructor	Description
(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 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 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 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 its Disposable or the subject is terminated.