Hi guys, reading a bit into akka streams and still can't quite get it. The overall idea is quite clear, but all the examples are rather simple and single block only. So I am trying to understand if this framework could a fit for my task. Let me describe a bit: let's say I have an eternal stream of trades. What I need to do is kind a different grouping, aggregating and so on, so the chain could be quite complicated. As far as I can see the stream interface supports only one type - in my case Trade. What if the semantics of my stream is add, update, delete? How would I organise the whole chain? And imagine on top of this lets say I need to group by the instrument and count trades per each group - which will push add, update, delete again... In fact, I was once working in a bank where they had an in-house framework similar to what I described - no back pressure though. So maybe akka streams is not the right tool for my task?