def add_consumer(self):
        """
        Adds a new consumer and returns its associated queue.

        Returns:
            asyncio.Queue: The queue for the newly added consumer.
        """
        queue = asyncio.Queue()
        self._consumers.append(queue)
        return queue

        Adds a new consumer and returns its associated queue.

        Returns:
            asyncio.Queue: The queue for the newly added consumer.
        
src/pipecat/processors/producer_processor.py