Connection reset with server in hot standby

[vharitonsky]

Currently connection reset does the following:
asyncpg v0.7.0
connection.py:370

async def reset(self):
        self._listeners = {}
        await self.execute('''
            SET SESSION AUTHORIZATION DEFAULT;
            RESET ALL;
            CLOSE ALL;
            UNLISTEN *;
            SELECT pg_advisory_unlock_all();
        ''')

Which is totally incomatible with postgresql in hot standby mode:

Transactions started during hot standby will never be assigned a transaction ID and cannot write to the system write-ahead log. Therefore, the following actions will produce error messages:
...
LISTEN, UNLISTEN, NOTIFY

Maybe there is a way to explicitly listen and then unlisten only in case listen command was issued?

[elprans]

Yes, this is definitely an issue. The best approach, IMO, would be to add a special Connection method to determine the state of the remote side.