Method unsubscribe

uncommon_route/events.py:30–32

(self, queue: asyncio.Queue[dict[str, Any]])

        return queue

    async def unsubscribe(self, queue: asyncio.Queue[dict[str, Any]]) -> None:
        async with self._lock:
            self._subscribers.discard(queue)

    def publish(self, event: dict[str, Any]) -> None:
        """Non-blocking fan-out. Safe to call from any async context."""