Uses of Class
io.reactivex.rxjava3.subjects.ReplaySubject
Packages that use ReplaySubject
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 ReplaySubject in io.reactivex.rxjava3.subjects
Fields in io.reactivex.rxjava3.subjects declared as ReplaySubjectModifier and TypeFieldDescription(package private) final ReplaySubject
<T> ReplaySubject.ReplayDisposable.state
Methods in io.reactivex.rxjava3.subjects that return ReplaySubjectModifier and TypeMethodDescriptionstatic <T> @NonNull ReplaySubject
<T> ReplaySubject.create()
Creates an unbounded replay subject.static <T> @NonNull ReplaySubject
<T> ReplaySubject.create
(int capacityHint) Creates an unbounded replay subject with the specified initial buffer capacity.(package private) static <T> ReplaySubject
<T> ReplaySubject.createUnbounded()
Creates an unbounded replay subject with the bounded-implementation for testing purposes.static <T> @NonNull ReplaySubject
<T> ReplaySubject.createWithSize
(int maxSize) Creates a size-bounded replay subject.static <T> @NonNull ReplaySubject
<T> ReplaySubject.createWithTime
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Creates a time-bounded replay subject.static <T> @NonNull ReplaySubject
<T> ReplaySubject.createWithTimeAndSize
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int maxSize) Creates a time- and size-bounded replay subject.Constructors in io.reactivex.rxjava3.subjects with parameters of type ReplaySubjectModifierConstructorDescription(package private)
ReplayDisposable
(Observer<? super T> actual, ReplaySubject<T> state)