async def aggregate(self, text: str) -> Optional[str]:
        """Aggregates the specified text with the currently accumulated text.

        This method should be implemented to define how the new text contributes
        to the aggregation process. It returns the updated aggregated text if
        it's ready to be processed, or None otherwise.

        Args:
            text (str): The text to be aggregated.

        Returns:
            Optional[str]: The updated aggregated text or None if aggregated
            text is not ready.

        """
        pass
Aggregates the specified text with the currently accumulated text.

        This method should be implemented to define how the new text contributes
        to the aggregation process. It returns the updated aggregated text if
        it's ready to be processed, or None otherwise.

        Args:
            text (str): The text to be aggregated.

        Returns:
            Optional[str]: The updated aggregated text or None if aggregated
            text is not ready.

        
src/pipecat/utils/text/base_text_aggregator.py