Hello
I wonder what is the reason behind Publisher created from Sink.asPublisher timing out behavior that is enabled by default? Is this to prevent resource leaking? I stumbled upon this some time ago and I found this kind of unintuitive.
Yes, the timeout is to avoid resource leaks when a publisher/subscriber is never used.
There are global settings akka.stream.materializer.subscription-timeout.mode and akka.stream.materializer.subscription-timeout.timeout that you can use to change the default behavior in a particular application where you want to loosen up that timeout or are not interested in that safety net at all. akka/reference.conf at main · akka/akka · GitHub
1 Like
Found of lots of info in this blog thanks for sharing this keep it up.