I have two uses cases that I'm used to from using CEP systems like Esper and I'm trying to figure out if I can implements them (easily) with Akka Streams:
1) test if in a stream of events ALL new events satisfy some predicate during some finite interval of time, which starts at the time the predicate yields true the first time. This is useful to generate alerts on a stream of measurements but only if some faulty condition persists for some given time. 2) test is some event does NOT occur after some other event within some finite duration My question is if these are supported by existing aka streams flow graph DSL elements or if a custom transformer is required. If the latter, I'd appreciate any pointers on how to approach writing it. Thanks, Frank -- >>>>>>>>>> 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
