Re: [akka-user] [akka-stream] Wait until two sinks are completed

2015-12-26 Thread hbf
Thanks a lot for your reply, Konrad – I have overlooked that overload of GraphDSL.create() and your suggestion works great! As a note, my user case is actually about *n *sinks that I need to combine in this way. I am doing this via recursion right now, which again works great. – Kaspar On

[akka-user] [akka-stream] Wait until two sinks are completed

2015-12-22 Thread hbf
Hey everybody, I can create a sink that broadcasts incoming messages to a given list of sinks. How can I make that sink materialize a future that completes when the downstream sinks have completed? For example, final Source in = Source.from(Arrays.asList(1, 2, 3,