I solved this particular itch of mine with help of Beam::Wire. You might also want to check Beam::Minion.

EDIT: see this: https://preaction.github.io/Data-Workflows-With-Beam/#/