This commit is contained in:
yumoqing 2024-09-11 13:03:31 +08:00
parent 95947c5fb8
commit 282313b555

View File

@ -31,11 +31,9 @@ class MyTrackBase(MediaStreamTrack):
async def recv(self): async def recv(self):
if self.source is None: if self.source is None:
return None return None
if self.track.readyState != 'live':
self.reload()
f = await self.source.audio.recv() 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 return f