Skip to content

Commit 6f1b69a

Browse files
committed
Update audio_mixer.py
1 parent b62bb7c commit 6f1b69a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

livekit-rtc/livekit/rtc/audio_mixer.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,9 @@ def add_stream(self, stream: AsyncIterator[AudioFrame]) -> None:
7272
Args:
7373
stream (AsyncIterator[AudioFrame]): An async iterator that produces AudioFrame objects.
7474
"""
75+
if self._ending:
76+
raise RuntimeError("Cannot add stream after mixer has been closed")
77+
7578
self._streams.add(stream)
7679
if stream not in self._buffers:
7780
self._buffers[stream] = np.empty((0, self._num_channels), dtype=np.int16)

0 commit comments

Comments
 (0)