Additional Notes
How does a Subscriber signal it can’t keep up?
Track: Java
Topic: Reactive Streams
Focus: Backpressure Strategies
Java: Backpressure Strategies
Answer
A Subscriber uses Subscription.request(n) to control the rate.
In Reactive Streams, a slow Subscriber can manage the data flow by indicating the number of items it can handle using request(n). This prevents memory overflow. For example, if a Subscriber can process only 5 items at a time, it will call request(5).
In Reactive Streams, a slow Subscriber can manage the data flow by indicating the number of items it can handle using request(n). This prevents memory overflow. For example, if a Subscriber can process only 5 items at a time, it will call request(5).
Topics: Backpressure Strategies Java Reactive Streams