Implement Backpressure pattern

[iluwatar]

Description

Backpressure is a mechanism used in reactive or streaming systems to prevent overwhelm by controlling the flow of data from producers to consumers. When a consumer cannot process data quickly enough, it signals the producer to slow down or buffer output. This ensures the system remains stable under high load and avoids excessive memory usage or dropped messages.

Key Elements

• Reactive Streams: In Java, frameworks like Project Reactor or RxJava implement backpressure with APIs allowing consumers to request data at a sustainable rate.
• Flow Control: Producers honor the consumer’s demand by sending data only as requested.
• Buffering & Throttling: If the consumer is busy, the producer may buffer data or reduce emission rate.
• Stability & Resilience: Helps prevent overproduction, out-of-memory errors, and overall system degradation under heavy load.

References

1. Reactive Streams Specification
2. Project Reactor Reference Guide (Backpressure)
3. Java Design Patterns – Contribution Guidelines

Acceptance Criteria

• Create a new module or package named backpressure (or similar).
• Implement a simple producer-consumer flow illustrating how backpressure prevents overload.
• Demonstrate how a consumer can signal demand and how a producer respects that demand.
• Provide a README (or .md file) explaining the pattern and code architecture, along with diagrams if needed.
• Include tests showcasing the system’s behavior under normal and high load.
• Ensure compliance with project style and that all CI checks pass.

[sanurah]

@iluwatar can you assign this to me please?