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) Subject<java.lang.Object>	ObservableRepeatWhen.RepeatWhenObserver.signaller
(package private) Subject<java.lang.Throwable>	ObservableRetryWhen.RepeatWhenObserver.signaller
(package private) Subject<T>	ObservableWindowSubscribeIntercept.window

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

Constructor	Description
ObservableWindowSubscribeIntercept(Subject<T> source)
RepeatWhenObserver(Observer<? super T> actual, Subject<java.lang.Object> signaller, ObservableSource<T> source)
RepeatWhenObserver(Observer<? super T> actual, Subject<java.lang.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
class	AsyncSubject<T>	A Subject that emits the very last value followed by a completion event or the received error to Observers.
class	BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
class	PublishSubject<T>	A Subject that emits (multicasts) items to currently subscribed Observers and terminal events to current or late Observers.
class	ReplaySubject<T>	Replays events (in a configurable bounded or unbounded manner) to current and late Observers.
(package private) class	SerializedSubject<T>	Serializes calls to the Observer methods.
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) 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
@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

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