Re: [akka-user] PartitionWith with in order merge

Please take a look at https://github.com/paypal/squbs/blob/master/squbs-unicomplex/src/main/scala/org/squbs/unicomplex/OrderingStage.scala for ordering. I will be making changes in the next few weeks to put a limit on the internal buffer and make it more lenient with a flag (

Re: [akka-user] Stream deduping

It is not latest and greatest; however, here is an Akka Streams GraphStage implementation for deduplication: https://squbs.readthedocs.io/en/latest/deduplicate/. All happens in memory, so you need to watch for memory growing and potentially pass a custom registry that self cleans after a while.

Re: [akka-user] Strange behavior with unzip when fusing is on

Regards, Roland >> >> Sent from my iPhone >> >> On 21 Dec 2016, at 09:34, Endre Varga <endre.va...@lightbend.com> wrote: >> >> >> >> On Tue, Dec 20, 2016 at 11:34 PM, Anil Gursel <anilgur...@gmail.com> >> wrote: >> >>>

[akka-user] Strange behavior with unzip when fusing is on

I see that unzip does not pull the next element when fusing is on. I understand that when fusing is on, a message goes through the entire stream and then the next message goes through. However, is it still the case when `mapAsyncUnordered` is used? Please see the two tests at