Hi I need to make a fan-in stage where I zip together data of different streams with different frequency. Imagine that you have a stream of replayable realtime sensor data and anotherone of replayable hourly data. To make a simple example I have timestamped events like
realtimeStream = 1,2,3,4,5,6,7,8,9,10 slowerStream = 5, 10, 15 now I want them to zip-sync by keeping the most recent value (with respect of the timestamp) (5,5), (6,5), (7,5), (8,5), (9,5), (10,10), .... As I do not know if (or how) the slower steam is aggregated I can not use a single custom stage because of the issue described here https://github.com/akka/akka/issues/23269 So in a nutshell I would need to: * filter data which is not young enough compared to the other streams * keep repeating data als long as nothing younger is provided (like Flow.expand) * zip synchronized elements into a tupl like event Any good idea how I could solve that problem is appreciated. I have tried to work around this by using a shared state actor but this is hell difficult to implement. Thx a lot Christian -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
