Uses of Class
io.reactivex.rxjava3.processors.ReplayProcessor
Packages that use ReplayProcessor
Package
Description
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 ReplayProcessorModifier and TypeFieldDescription(package private) final ReplayProcessor
<T> ReplayProcessor.ReplaySubscription.state
Methods in io.reactivex.rxjava3.processors that return ReplayProcessorModifier and TypeMethodDescriptionstatic <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 TimeUnit unit, @NonNull Scheduler scheduler) Creates a time-bounded ReplayProcessor.static <T> @NonNull ReplayProcessor
<T> ReplayProcessor.createWithTimeAndSize
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int maxSize) Creates a time- and size-bounded ReplayProcessor.Constructors in io.reactivex.rxjava3.processors with parameters of type ReplayProcessorModifierConstructorDescription(package private)
ReplaySubscription
(org.reactivestreams.Subscriber<? super @NonNull T> actual, ReplayProcessor<@NonNull T> state)