Uses of Class
io.reactivex.rxjava3.subjects.Subject

Packages that use Subject

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 Subject in io.reactivex.rxjava3.internal.operators.observable

Fields in io.reactivex.rxjava3.internal.operators.observable declared as Subject

Modifier and Type	Field	Description
(package private) final Subject<Object>	ObservableRepeatWhen.RepeatWhenObserver.signaller
(package private) final Subject<Throwable>	ObservableRetryWhen.RepeatWhenObserver.signaller
(package private) final Subject<T>	ObservableWindowSubscribeIntercept.window

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Subject

Modifier	Constructor	Description
(package private)	ObservableWindowSubscribeIntercept(Subject<T> source)
(package private)	RepeatWhenObserver(Observer<? super T> actual, Subject<Object> signaller, ObservableSource<T> source)
(package private)	RepeatWhenObserver(Observer<? super T> actual, Subject<Throwable> signaller, ObservableSource<T> source)

Uses of Subject in io.reactivex.rxjava3.subjects

Subclasses of Subject in io.reactivex.rxjava3.subjects

Modifier and Type	Class	Description
final class	AsyncSubject<T>	A Subject that emits the very last value followed by a completion event or the received error to Observers.
final class	BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
final class	PublishSubject<T>	A Subject that emits (multicasts) items to currently subscribed Observers and terminal events to current or late Observers.
final class	ReplaySubject<T>	Replays events (in a configurable bounded or unbounded manner) to current and late Observers.
(package private) final class	SerializedSubject<T>	Serializes calls to the Observer methods.
final class	UnicastSubject<T>	A Subject that queues up events until a single Observer subscribes to it, replays those events to it until the Observer catches up and then switches to relaying events live to this single Observer until this UnicastSubject terminates or the Observer disposes.

Fields in io.reactivex.rxjava3.subjects declared as Subject

Modifier and Type	Field	Description
(package private) final Subject<T>	SerializedSubject.actual	The actual subscriber to serialize Subscriber calls to.

Methods in io.reactivex.rxjava3.subjects that return Subject

Modifier and Type	Method	Description
final @NonNull Subject<T>	Subject.toSerialized()	Wraps this Subject and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.

Constructors in io.reactivex.rxjava3.subjects with parameters of type Subject

Modifier	Constructor	Description
(package private)	SerializedSubject(Subject<T> actual)	Constructor that wraps an actual subject.