async def METHOD_NAME(self, connection: SendConnection, req: Unsubscribe) -> None:
    self._check_topics(req.topics)
    for topic in req.topics:
        self._topic_info[topic].subscribers.discard(connection.session_id)