async def set_transport_ready(self, frame: StartFrame):
        """To be called when the transport is ready to stream."""
        # Create audio input queue and task if needed.
        self._create_audio_task()
To be called when the transport is ready to stream.
src/pipecat/transports/base_input.py