Lubos Palisek
Lubos Palisek
Just a note - this solution seems not to propagate shutdown signal (when `Sink` is cancelled/failed you don't get this information in `Source`)
Thanks @johanandren. I see cancellation is propagated. I was burnt by "hidden" buffer few weeks ago too. It is confusing when akka stream operators are composed from reactive streams components...
It looks more likely to be the same bug as describred here https://github.com/rancher/community-catalog/issues/40