Mason

I haven't tested it yet, but definitely plan on switching over to that when it's no longer experimental. If it resolves our performance issues, we would like to use that...

Yep the streaming functionality fixed the issues we were having that required us to use dedupe.

My error callback is just logging the error: ``` async def on_error(e): LOGGER.exception(f"NATS Error: {e}") ``` The error seems to specifically be happening during the TLS upgrade - is there...

It seems to reconnect in other cases just fine - if i turn off the nats server or start up my app without the server running it will continuously reconnect...