Thank for this, this style of flow-based programming has something that I have been sorta playing around in terms of concept for building a larger elixir application with flexible data pipelines.

This approach combined with Flowex, should make the implementation of what I been working on a lot easier.