The reason for the behavior you are observing is a race condition. The
effects of close! on the pub aren't synchronous. Even though the channel is
immediately closed before return, consumers need time to determine that it
has been closed. At the point in time the pub determines that the source
Hi all!
I’m working with core.async pub/sub and ran into an issue which I don’t
quite understand. According to the clojure.core.async/sub docstring:
> By default the channel will be closed when the source closes
This is not the behaviour I’m seeing when I call
clojure.core.async/unsub-all imme
