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 the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.

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)