Uses of Class
io.reactivex.rxjava3.subjects.Subject
Packages that use Subject
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 Subject in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as SubjectModifier and TypeFieldDescriptionObservableRepeatWhen.RepeatWhenObserver.signaller
ObservableRetryWhen.RepeatWhenObserver.signaller
ObservableWindowSubscribeIntercept.window
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type SubjectModifierConstructorDescription(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.subjectsModifier and TypeClassDescriptionfinal class
AsyncSubject<T>
A Subject that emits the very last value followed by a completion event or the received error to Observers.final class
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.final class
A Subject that emits (multicasts) items to currently subscribedObserver
s and terminal events to current or lateObserver
s.final class
Replays events (in a configurable bounded or unbounded manner) to current and lateObserver
s.(package private) final class
Serializes calls to the Observer methods.final class
A Subject that queues up events until a singleObserver
subscribes to it, replays those events to it until theObserver
catches up and then switches to relaying events live to this singleObserver
until thisUnicastSubject
terminates or theObserver
disposes.Fields in io.reactivex.rxjava3.subjects declared as SubjectModifier and TypeFieldDescriptionSerializedSubject.actual
The actual subscriber to serialize Subscriber calls to.Methods in io.reactivex.rxjava3.subjects that return SubjectModifier and TypeMethodDescriptionSubject.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 SubjectModifierConstructorDescription(package private)
SerializedSubject
(Subject<T> actual) Constructor that wraps an actual subject.