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
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,