Skip to content

Commit 8d3f4fe

Browse files
committed
fix: apply devin suggestion
1 parent 07fec79 commit 8d3f4fe

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

livekit-rtc/livekit/rtc/audio_stream.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -319,12 +319,12 @@ async def aclose(self) -> None:
319319
This method cleans up resources associated with the audio stream and waits for
320320
any pending operations to complete.
321321
"""
322-
if self._processor is not None and not self._processor_leave_open:
323-
self._processor._close()
324322
if self._track is not None:
325323
self._track._unregister_audio_stream(self)
326324
self._ffi_handle.dispose()
327325
await self._task
326+
if self._processor is not None and not self._processor_leave_open:
327+
self._processor._close()
328328

329329
def _is_event(self, e: proto_ffi.FfiEvent) -> bool:
330330
return e.audio_stream_event.stream_handle == self._ffi_handle.handle

livekit-rtc/livekit/rtc/track.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ def _push_processor_metadata_to_stream(self, stream: AudioStream, room: Optional
6565
return
6666

6767
if room is None:
68-
# track left a room clear processor's room context
68+
# track left a room - clear processor's room context
6969
stream._processor._on_stream_info_cleared()
7070
stream._processor._on_credentials_cleared()
7171
return

0 commit comments

Comments
 (0)