Tim
Maybe just moving them to the top level is the simplest approach?
But the stream could be consumed more than once?
The jsdocs need updating, as the key is not optional.
Thanks! If you could add a `patch` changeset for this, as it touches implementation code.
If you rebase against the latest `main` branch we can get this merged :)
I'll wait for the minimal repro before going any further. Will need to see at which point the messages are getting stuck, just to make sure it isn't the underlying...
How frequent are the messages? And how is postgres hosted in this case?
> I think I've resolved the issue - the frequency of messages is very low atm due to it just being my testing. That being said, switching from using Supabases...