Hi, We're using akka-streams to process a stream of messages, which result in some actions. Now, we need to find the number of messages being processed by the stream (well, not that plain vanilla, actually each message has a set of attributes, say, m_type, m_cmp, m_origin, ...).
One solution would be to have a counter in one of the stages that would keep track of that & update. Other I'm hinted from the akka-docs could be the `M` materialized values of the stream (that we seldom use currently). However, I'm not so sure, how to start a runnable-graph once, & then keep on invoking the materialized value at each interval of let's say 5 mins (to kind of find messages processed so far) ? We need the stream running continuously, so, doing a someGraph.run again and again doesn't make sense to find the materialized value at various intervals. http://doc.akka.io/docs/akka/2.4.4/scala/stream/stream-quickstart.html#reactive-tweets Would be thankful for some guidance here. Thanks, Durga -- >>>>>>>>>> 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.
