format

Author: chenosaurus

examples/local_audio/db_meter.py

@@ -136,7 +136,9 @@ def format_dual_meters(mic_db: float, room_db: float) -> str:
     return f"{mic_meter}{room_meter}"
 
 
-def display_dual_db_meters(mic_db_receiver, room_db_receiver, room_name: str = "Audio Levels Monitor") -> None:
+def display_dual_db_meters(
+    mic_db_receiver, room_db_receiver, room_name: str = "Audio Levels Monitor"
+) -> None:
     """
     Display dual dB meters continuously until interrupted.
 
@@ -152,7 +154,9 @@ def display_dual_db_meters(mic_db_receiver, room_db_receiver, room_name: str = "
 
         print()  # Start on a new line
         print(f"\x1b[92mRoom [{room_name}]\x1b[0m")
-        print("\x1b[2m────────────────────────────────────────────────────────────────────────────────\x1b[0m")
+        print(
+            "\x1b[2m────────────────────────────────────────────────────────────────────────────────\x1b[0m"
+        )
 
         while True:
             # Check for new data (non-blocking)
@@ -174,7 +178,11 @@ def display_dual_db_meters(mic_db_receiver, room_db_receiver, room_name: str = "
             current_time = time.time()
             if current_time - last_update >= DB_METER_UPDATE_INTERVAL_MS / 1000.0:
                 # Clear current line and display meters in place
-                print(f"\r\x1b[K{format_dual_meters(current_mic_db, current_room_db)}", end="", flush=True)
+                print(
+                    f"\r\x1b[K{format_dual_meters(current_mic_db, current_room_db)}",
+                    end="",
+                    flush=True,
+                )
                 last_update = current_time
 
             # Small sleep to prevent busy waiting

examples/local_audio/full_duplex.py

@@ -82,7 +82,7 @@ def on_track_unsubscribed(
             target=display_single_db_meter,
             args=(mic_db_queue,),
             kwargs={"label": "Mic Level: "},
-            daemon=True
+            daemon=True,
         )
         meter_thread.start()
 
@@ -91,9 +91,7 @@ def on_track_unsubscribed(
 
         # Monitor microphone dB levels
         async def monitor_mic_db():
-            mic_stream = rtc.AudioStream(
-                track, sample_rate=48000, num_channels=1
-            )
+            mic_stream = rtc.AudioStream(track, sample_rate=48000, num_channels=1)
             try:
                 async for frame_event in mic_stream:
                     frame = frame_event.frame

examples/local_audio/publish_mic.py

@@ -57,17 +57,13 @@ async def main() -> None:
 
         # Start dB meter display in a separate thread
         meter_thread = threading.Thread(
-            target=display_single_db_meter,
-            args=(mic_db_queue, "Mic: "),
-            daemon=True
+            target=display_single_db_meter, args=(mic_db_queue, "Mic: "), daemon=True
         )
         meter_thread.start()
 
         # Monitor microphone dB levels
         async def monitor_mic_db():
-            mic_stream = rtc.AudioStream(
-                track, sample_rate=48000, num_channels=1
-            )
+            mic_stream = rtc.AudioStream(track, sample_rate=48000, num_channels=1)
             try:
                 async for frame_event in mic_stream:
                     frame = frame_event.frame

livekit-rtc/livekit/rtc/media_devices.py

@@ -149,7 +149,7 @@ def __init__(
         self._play_task: Optional[asyncio.Task] = None
         self._running = False
         self._delay_estimator = delay_estimator
-        
+
         # Internal mixer for add_track/remove_track API
         self._mixer: Optional[AudioMixer] = None
         self._track_streams: dict[str, AudioStream] = {}  # track.sid -> AudioStream
@@ -223,21 +223,14 @@ def add_track(self, track: Track) -> None:
         """
         if track.sid in self._track_streams:
             raise ValueError(f"Track {track.sid} already added to player")
-        
+
         # Create mixer on first track addition
         if self._mixer is None:
-            self._mixer = AudioMixer(
-                sample_rate=self._sample_rate,
-                num_channels=self._num_channels
-            )
-        
+            self._mixer = AudioMixer(sample_rate=self._sample_rate, num_channels=self._num_channels)
+
         # Create audio stream for this track
-        stream = AudioStream(
-            track,
-            sample_rate=self._sample_rate,
-            num_channels=self._num_channels
-        )
-        
+        stream = AudioStream(track, sample_rate=self._sample_rate, num_channels=self._num_channels)
+
         self._track_streams[track.sid] = stream
         self._mixer.add_stream(stream)
 
@@ -252,13 +245,13 @@ async def remove_track(self, track: Track) -> None:
         stream = self._track_streams.pop(track.sid, None)
         if stream is None:
             return
-        
+
         if self._mixer is not None:
             try:
                 self._mixer.remove_stream(stream)
             except Exception:
                 pass
-        
+
         try:
             await stream.aclose()
         except Exception:
@@ -276,13 +269,10 @@ async def start(self) -> None:
         """
         if self._play_task is not None and not self._play_task.done():
             raise RuntimeError("Playback already started")
-        
+
         if self._mixer is None:
-            self._mixer = AudioMixer(
-                sample_rate=self._sample_rate,
-                num_channels=self._num_channels
-            )
-        
+            self._mixer = AudioMixer(sample_rate=self._sample_rate, num_channels=self._num_channels)
+
         async def _playback_loop():
             """Internal playback loop that consumes frames from the mixer."""
             self._running = True
@@ -300,40 +290,40 @@ async def _playback_loop():
                     self._stream.close()
                 except Exception:
                     pass
-        
+
         self._play_task = asyncio.create_task(_playback_loop())
 
     async def aclose(self) -> None:
         """Stop playback and close the output stream.
-        
+
         This also cleans up all added tracks and the internal mixer.
         """
         self._running = False
-        
+
         # Cancel playback task if running
         if self._play_task is not None and not self._play_task.done():
             self._play_task.cancel()
             try:
                 await self._play_task
             except asyncio.CancelledError:
                 pass
-        
+
         # Clean up all track streams
         for stream in list(self._track_streams.values()):
             try:
                 await stream.aclose()
             except Exception:
                 pass
         self._track_streams.clear()
-        
+
         # Close mixer
         if self._mixer is not None:
             try:
                 await self._mixer.aclose()
             except Exception:
                 pass
             self._mixer = None
-        
+
         # Close output stream
         try:
             self._stream.stop()