I’m doing some maths between both stream entries.
I think I finally found the way to go using Flow library, especially with https://hexdocs.pm/flow/Flow.html#bounded_join/7
It will help me to join my streams and also to improve performance by leveraging on multiple cores. I will let you know how that finally turned out!