Re: [akka-user] Merge matching elements of multiple streams into Tuples

Hey Patrik! I got it working with a running test :) Still need to properly stress-test it, though. see my repo Had a lot of pen-and-paper design upfront, to get the merge-logic right, but the implementation was pretty straightforward. I

Re: [akka-user] Merge matching elements of multiple streams into Tuples

I found out what the problem is. The UniformFanInShape isn't available in a scala-class in the sourcecode since it is being generated from a template. akka-stream/src/main/boilerplate/akka/stream/FanInShape.scala.template I generated the sourcecode and try to work through the logic now. Thanks f

Re: [akka-user] Merge matching elements of multiple streams into Tuples

On Fri, Nov 20, 2015 at 2:09 PM, Florian Witteler < florian.witte...@googlemail.com> wrote: > Thanks for getting back to me. > No need to be sorry - the docs of the akka-framework are imho the most > qualitative docs of all frameworks I know. And quality takes time. > > After looking through the >

Re: [akka-user] Merge matching elements of multiple streams into Tuples

Thanks for getting back to me. No need to be sorry - the docs of the akka-framework are imho the most qualitative docs of all frameworks I know. And quality takes time. After looking through the 'releasing-akka-stream-and-http-experimental-2.0-M1' branch I think I can take akka.stream.scaladsl.

Re: [akka-user] Merge matching elements of multiple streams into Tuples

On Fri, Nov 20, 2015 at 12:03 PM, Florian Witteler < florian.witte...@googlemail.com> wrote: I have an elasticsearch-database with all our articles. Each tenant has its > own index. These indexes are denormalized (the common properties of an > article are duplicated into each index) > We are about

[akka-user] Merge matching elements of multiple streams into Tuples

I have an elasticsearch-database with all our articles. Each tenant has its own index. These indexes are denormalized (the common properties of an article are duplicated into each index) We are about to implement streaming of articles with akka http and use the elasticsearch-drivers' reactive st