Hi Martynas,
Thank you very much! Yes, I have seen the documentation. In my case it was not pure deadlock, but eagerComplete configuration. When I set it to false my flow never ends, but when it is true it seems to be ending earlier than it should.
I was even thinking about streaming “loop” data into a separate Sink, then convert it into a source like explained here: Create Source from Sink (and vice versa) and merge newly created Source with the initial one. In this case I will have less problems with back-pressure and eagerComplete.
– Sergii