1 个仓库
Caching a specific number or duration of emitted elements in a sequence for replay to later subscribers.
Distinct from Data Caching: Distinct from Data Caching: focuses specifically on the replay of elements within a reactive sequence based on count or time.
Explore 1 awesome GitHub repository matching data & databases · Sequence. Refine with filters or upvote what's useful.
Reactor Core is a reactive programming toolkit and non-blocking foundation for composing asynchronous data pipelines on the JVM. It serves as an asynchronous stream processing framework and a backpressure management system, allowing developers to transform, filter, and combine sequences of events while regulating data flow between producers and consumers to prevent resource exhaustion. The library differentiates itself through a sophisticated concurrency scheduling system and demand-based flow control. It decouples signal processing from specific threads using a scheduler registry and provide
Stores emitted elements and replays them to late subscribers based on a fixed count or time duration.