backpressure

Overview ¶

Backpressure demo: a fast source feeding a deliberately slow sink through tiny edges. The bounded edges fill up, block the upstream stages, and throttle the source to the sink's pace — memory stays bounded and no record is ever dropped, with zero tuning.

Run with:

go run ./examples/backpressure/