The solution for this in Elixir is to use GenStage actors, which provides backpressure by allowing downstream processes to ask for data to process.

Check out this video which describes it pretty well: https://youtu.be/srtMWzyqdp8?t=1027