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 subscribedObserver
.class
PublishSubject<T>
A Subject that emits (multicasts) items to currently subscribedObserver
s and terminal events to current or lateObserver
s.class
ReplaySubject<T>
Replays events (in a configurable bounded or unbounded manner) to current and lateObserver
s.(package private) class
SerializedSubject<T>
Serializes calls to the Observer methods.class
UnicastSubject<T>
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 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.
-