Hi,
The explanation is that you use Source.empty which immediately completes
the stream. Since you overrode onUpstreamFinish() to ignore this
completion, it just gets stuck. Below your broken stage there are no
timeouts (timeouts don't apply to a whole stream, only to that exact
communication
Hi Akka Team, All,
I have few custom stages, recently i find out that one of them under
certain conditions was not properly completing graph stage, which was
causing graph to run forever.
I have timeouts attached to graph and would expect it to fail with timeout
but it never happened. I
