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 pre
ala/stream-cookbook.html
>
> Hope this helps, and feel free to ask for help in case you get stuck :-)
>
> --
> Konrad
>
> On Thu, Jan 15, 2015 at 3:57 AM, Frank Sauer > wrote:
>
>> I have two uses cases that I'm used to from using CEP systems like Esper
>
ctacular
ways as expected
I have no idea how to implement this correctly. It looked pretty simple at
first, but alas...
On Wednesday, January 21, 2015 at 8:51:21 PM UTC-5, Frank Sauer wrote:
>
> Thanks, I came up with the following, but I have some questions:
>
> /**
>
Thanks for the pointers Endre, I’ll explore those ideas.
Frank
> On Jan 22, 2015, at 4:02 AM, Endre Varga wrote:
>
>
>
> On Thu, Jan 22, 2015 at 5:07 AM, Frank Sauer <mailto:fsaue...@gmail.com>> wrote:
> Update, in a simple test scenario like so
>
>
