Uses of Class
io.reactivex.rxjava3.subjects.ReplaySubject
-
Packages that use ReplaySubject Package Description 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 ReplaySubject in io.reactivex.rxjava3.subjects
Fields in io.reactivex.rxjava3.subjects declared as ReplaySubject Modifier and Type Field Description (package private) ReplaySubject<T>
ReplaySubject.ReplayDisposable. state
Methods in io.reactivex.rxjava3.subjects that return ReplaySubject Modifier and Type Method Description static <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 java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler)
Creates a time-bounded replay subject.static <T> @NonNull ReplaySubject<T>
ReplaySubject. createWithTimeAndSize(long maxAge, @NonNull java.util.concurrent.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 ReplaySubject Constructor Description ReplayDisposable(Observer<? super T> actual, ReplaySubject<T> state)
-