fix(backend/postgres): allow concurrent pubs

This fix adds an asyncio.Lock to avoid
`asyncpg.exceptions._base.InterfaceError: cannot perform operation: another operation is in progress`

fixes #22

Author: pwoolvett

broadcaster/_backends/postgres.py

@@ -13,6 +13,7 @@ def __init__(self, url: str):
 
     async def connect(self) -> None:
         self._conn = await asyncpg.connect(self._url)
+        self._lock = asyncio.Lock()
         self._listen_queue: asyncio.Queue = asyncio.Queue()
 
     async def disconnect(self) -> None:
@@ -25,7 +26,8 @@ async def unsubscribe(self, channel: str) -> None:
         await self._conn.remove_listener(channel, self._listener)
 
     async def publish(self, channel: str, message: str) -> None:
-        await self._conn.execute("SELECT pg_notify($1, $2);", channel, message)
+        async with self._lock:
+            await self._conn.execute("SELECT pg_notify($1, $2);", channel, message)
 
     def _listener(self, *args: Any) -> None:
         connection, pid, channel, payload = args