Why it matters

Backpressure shapes reliable streaming. Understanding shapes design.

Advertisement

The architecture

Consumer request(N).

Producer emits up to N.

Pause when quota consumed.

Backpressure protocolConsumer request(N)quotaProducer emitsup to NWait or dropwhen quota doneonBackpressureBuffer + onBackpressureDrop are Reactor strategies
Backpressure.
Advertisement

How it works end to end

Reactive Streams spec.

Reactor: request-based.

Buffer + drop + latest strategies.

Slow downstream shouldn't OOM.