Skip to content

Commit f880acc

Browse files
committed
more idiomatic python
1 parent 4919845 commit f880acc

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

livekit-rtc/livekit/rtc/audio_stream.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ async def _run(self):
273273
if audio_event.HasField("frame_received"):
274274
owned_buffer_info = audio_event.frame_received.frame
275275
frame = AudioFrame._from_owned_info(owned_buffer_info)
276-
if self._processor is not None:
276+
if self._processor is not None and self._processor.enabled:
277277
try:
278278
frame = self._processor._process(frame)
279279
except Exception:

livekit-rtc/livekit/rtc/frame_processor.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,10 +10,11 @@
1010
class FrameProcessor(Generic[T], ABC):
1111
@property
1212
@abstractmethod
13-
def is_enabled(self) -> bool: ...
13+
def enabled(self) -> bool: ...
1414

15+
@enabled.setter
1516
@abstractmethod
16-
def set_enabled(self, enable: bool): ...
17+
def enabled(self, value: bool) -> None: ...
1718

1819
def _update_stream_info(
1920
self,

0 commit comments

Comments
 (0)