Re: [akka-user] Connection state in Artery

2017-11-13 Thread Merlijn Boogerd
I will, thanks for your feedback, much appreciated! :) Op maandag 13 november 2017 17:10:28 UTC+1 schreef Patrik Nordwall: > > > > On Mon, Nov 13, 2017 at 4:43 PM, Merlijn Boogerd <merlijn...@trivento.nl > > wrote: > >> Hi Patrik, >> >> Thanks for

Re: [akka-user] Connection state in Artery

2017-11-13 Thread Merlijn Boogerd
u don't see any obvious problems in Artery/Aeron that make it a bad fit for my use case (using few connections at a time, but many over time)? Kind regards, Merlijn Op zondag 12 november 2017 18:25:16 UTC+1 schreef Patrik Nordwall: > > Hi Merlijn, > > > > On Sun, Nov 12, 20

[akka-user] Connection state in Artery

2017-11-12 Thread Merlijn Boogerd
Hi fellow hakkers, I have two questions regarding the Artery module (I am not considering the previous remoting as it will eventually get deprecated). I implemented a peer sampling service (HyParView) and am in the process of implementing a clustering service (Vicinity), both directly on top

[akka-user] Multiplexing protocols with Artery

2017-07-22 Thread Merlijn Boogerd
Dear hAkkers, What would the recommended way be of multiplexing several protocols with Artery? More specifically, I aim to implement NAT-traversal protocols such as STUN/TURN/ICE, which have a strict binary encoding (i.e. I cannot have Akka wrap its own metadata around the payload such as

Re: [akka-user] Non-monotonic incremental computation

2016-11-20 Thread Merlijn Boogerd
s. Probably best if you create an Akka github issue. > > /Patrik > lör 19 nov. 2016 kl. 12:06 skrev Merlijn Boogerd <merlijn...@trivento.nl > >: > >> Hi! For a while now I have developed an interest in developing data-flows >> which are non-monotonic (i.e. they

[akka-user] Non-monotonic incremental computation

2016-11-19 Thread Merlijn Boogerd
Hi! For a while now I have developed an interest in developing data-flows which are non-monotonic (i.e. they support updates and deletes), and incremental (between batch/stream, within the Spark community this is also called a continuous application). I have experimented with this in a

[akka-user] Possible bug in akka streams 2.0-M2 sliding window

2015-12-11 Thread Merlijn Boogerd
I have encountered something that is against my expectations in the sliding window of Akka streams 2.0-M2. Before I log an actual bug, could someone read along and check that this is actually a bug or a case of RTFM-better, or simply something subjective? The docs for Flow.sliding say: Apply

Re: [akka-user] Possible bug in akka streams 2.0-M2 sliding window

2015-12-11 Thread Merlijn Boogerd
Hi Roland, Op vrijdag 11 december 2015 11:42:34 UTC+1 schreef rkuhn: > > Hi Merlijn, > > The intuition is that the union of the output sequences should contain all > elements that are selected by the step and window parameters, but they need > to be present only once. > Clear, that nicely