diff --git a/rtcllm/aav.py b/rtcllm/aav.py index 4b5b658..37caf73 100644 --- a/rtcllm/aav.py +++ b/rtcllm/aav.py @@ -31,11 +31,9 @@ class MyTrackBase(MediaStreamTrack): async def recv(self): if self.source is None: return None + if self.track.readyState != 'live': + self.reload() f = await self.source.audio.recv() - while self.reloaded: - print('MyAudioTrack::recv(): will reload source') - f = await self.source.audio.recv() - self.reloaded = False return f