[akka-user] [Akka-streams] MergePrioritized with Java

Hi all, I am trying to implement flow with MergePrioritized shape using Java. However, there are no examples on how to connect ports. I tried something like this: int[] priorities = {1, 2, 3}; UniformFanInShape inputMergePrioritized = MergePrioritized .create(MyClass.class, priorities, true).s

[akka-user] Re: [Akka-streams] MergePrioritized with Java

Issue solved. I forgot to add shape to Graph. -- >> 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 receive

[akka-user] [Akka-Streams] MergePrioritized vs MergePreferred

Hi all, I have certain difficulties with merging different branches of flow. My flow looks like following: |-| | |-| |

[akka-user] Re: [Akka-Streams] MergePrioritized vs MergePreferred

By using MergePreferred I mean sequence of them. -- >> 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 recei

[akka-user] [akka-streams] How to test FanOut shapes?

Hi, I am writing tests for my application and I want to test function that returns Partition shape with two outlets. Are there any best practices on how to test Partition shapes? Thanks. Regards, Sergii -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>