类的使用
reactor.core.publisher.ReplayProcessor

使用ReplayProcessor的程序包

程序包	说明
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

reactor.core.publisher中ReplayProcessor的使用

返回ReplayProcessor的reactor.core.publisher中的方法

限定符和类型	方法和说明
static <T> ReplayProcessor<T>	ReplayProcessor.cacheLast() 已过时。 use Sinks.many().replay().latest() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <T> ReplayProcessor<T>	ReplayProcessor.cacheLastOrDefault(T value) 已过时。 use Sinks.many().replay().latestOrDefault(value) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <E> ReplayProcessor<E>	ReplayProcessor.create() 已过时。 use Sinks.many().replay().all() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <E> ReplayProcessor<E>	ReplayProcessor.create(int historySize) 已过时。 use Sinks.many().replay().limit(historySize) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <E> ReplayProcessor<E>	ReplayProcessor.create(int historySize, boolean unbounded) 已过时。 use Sinks.many().replay().limit(historySize) for bounded cases (unbounded == false) or Sinks.many().replay().all(bufferSize) otherwise (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <T> ReplayProcessor<T>	ReplayProcessor.createSizeAndTimeout(int size, java.time.Duration maxAge) 已过时。 use Sinks.many().replay().limit(size, maxAge) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <T> ReplayProcessor<T>	ReplayProcessor.createSizeAndTimeout(int size, java.time.Duration maxAge, Scheduler scheduler) 已过时。 use Sinks.many().replay().limit(size, maxAge, scheduler) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <T> ReplayProcessor<T>	ReplayProcessor.createTimeout(java.time.Duration maxAge) 已过时。 use Sinks.many().replay().limit(maxAge) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <T> ReplayProcessor<T>	ReplayProcessor.createTimeout(java.time.Duration maxAge, Scheduler scheduler) 已过时。 use Sinks.many().replay().limit(maxAge, scheduler) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.