No way to cancel a publish listener

[lmcd]

I'm using mqtt-nio with Swift Concurrency.
I'm looking to cleanup after every disconnection, and re-establish everything when reconnecting. Ideally, MQTTPublishListener will finish when the channel closes, allowing the control flow of the publish stream to gracefully exit and then for a reconnection attempt to occur - but this currently only happens on shutdown.

Is it worth finishing a MQTTPublishListener stream on channel close also?

[adam-fowler]

MQTTPublishListeners don't finish on connection close because subscriptions are persisted across sessions, if the cleanSession flag is set to false on connection.

I could look into cancelling them if the cleanSession flag is set on connection.

[adam-fowler]

#171 will finish publish listeners on close of connection if cleanSession is set to true.

[adam-fowler]

Fix is in release 2.12.1