subject:"\[akka\-user\] Re\: Completion of a Graph with a Cycle"

Re: [akka-user] Re: Completion of a Graph with a Cycle

2016-10-12 Thread Konrad Malawski

Have you seen http://doc.akka.io/docs/akka/2.4/scala/stream/stream-dynamic.html#Controlling_graph_completion_with_KillSwitch ? -- Konrad `ktoso` Malawski Akka @ Lightbend On 12 October 2016 at 15:42:01, external.stefan.wach...@bosch-si.com (

[akka-user] Re: Completion of a Graph with a Cycle

2016-10-12 Thread external . stefan . wachter

I think I found a general solution in the meantime. We have a "semaphore" component that wraps a flow and tracks / delimits the number of elements that may be "in flight" at the same time in the wrapped flow (the flow must have a 1:1 relationship between its input and output).The semaphore