Hacker News Reader

Elixir has several tools built around solving this problem; GenStage being the foundation library and Flow and Broadway at a higher level.

On a related note, there's also work on an FBP implementation in Elixir: https://github.com/pcmarks/ElixirFBP