Uses of Class
io.reactivex.rxjava3.processors.ReplayProcessor
-
Packages that use ReplayProcessor Package Description io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
. -
-
Uses of ReplayProcessor in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as ReplayProcessor Modifier and Type Field Description (package private) ReplayProcessor<T>
ReplayProcessor.ReplaySubscription. state
Methods in io.reactivex.rxjava3.processors that return ReplayProcessor Modifier and Type Method Description static <T> @NonNull ReplayProcessor<T>
ReplayProcessor. create()
Creates an unbounded ReplayProcessor.static <T> @NonNull ReplayProcessor<T>
ReplayProcessor. create(int capacityHint)
Creates an unbounded ReplayProcessor with the specified initial buffer capacity.(package private) static <T> ReplayProcessor<T>
ReplayProcessor. createUnbounded()
Creates an unbounded ReplayProcessor with the bounded-implementation for testing purposes.static <T> @NonNull ReplayProcessor<T>
ReplayProcessor. createWithSize(int maxSize)
Creates a size-bounded ReplayProcessor.static <T> @NonNull ReplayProcessor<T>
ReplayProcessor. createWithTime(long maxAge, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler)
Creates a time-bounded ReplayProcessor.static <T> @NonNull ReplayProcessor<T>
ReplayProcessor. createWithTimeAndSize(long maxAge, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler, int maxSize)
Creates a time- and size-bounded ReplayProcessor.Constructors in io.reactivex.rxjava3.processors with parameters of type ReplayProcessor Constructor Description ReplaySubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, ReplayProcessor<@NonNull T> state)
-