async def handle_interruption(self):
        """Handles interruptions. When an interruption occurs it is possible
        that we might want to discard the aggregated text or do some internal
        modifications to the aggregated text.

        """
        pass
Handles interruptions. When an interruption occurs it is possible
        that we might want to discard the aggregated text or do some internal
        modifications to the aggregated text.

        
src/pipecat/utils/text/base_text_aggregator.py