<div dir="ltr">Hi Loïc,<div><br></div><div>This is for unit tests only. In the real-life scenario actually the gen_server itself (result_subscriber.erl) will be the consumer, so gen_server:call() won't be needed. There could be multiple consumers also.</div>
<div>As for the delivery on specific interval - this is what I call a "batch window" and is on top of my "to do" list. Currently the result (output) is emitted on every input.</div><div><br></div><div>
Best regards,</div><div>Vasco</div><div><br></div><div class="gmail_extra"><br><br><div class="gmail_quote">On Mon, Jan 6, 2014 at 1:06 AM, Loïc Hoguin <span dir="ltr"><<a href="mailto:essen@ninenines.eu" target="_blank">essen@ninenines.eu</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-color:rgb(204,204,204);border-left-style:solid;padding-left:1ex">That looks very good. One question though. You always do a gen_server call to retrieve results, any way to get them as they come, perhaps delivered every Interval?<br>
<br>Sent from my ASUS Padfone<div class=""><div class="h5"><br><br>Vassil Kolarov <<a href="mailto:vasco@vas.io" target="_blank">vasco@vas.io</a>> wrote:<br><br><div dir="ltr">Hi all,<div><br></div><div>I'd like to announce a project called 'Rivus'.  The goal of the project is implementation of complex events processing application in Erlang, which uses a DSL similar to ESPER's EPL. It is in a very early stage, but could be considered sort of a "MVP".</div>

<div><br></div><div>Here is the GitHub repository: <a href="https://github.com/vascokk/rivus_cep" target="_blank">https://github.com/vascokk/rivus_cep</a> </div><div><br></div><div>Hope you'll find it interesting and useful.<br>
</div>
<div><br></div><div>Best regards,</div><div>Vasco</div></div>
</div></div></blockquote></div><br></div></div>