Skip to content

Commit 329671b

Browse files
authored
(0.x) fix decoder: if no data was pushed, close the output channel (#1881)
1 parent 97402e2 commit 329671b

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

.changeset/long-bikes-explain.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"livekit-agents": patch
3+
---
4+
5+
fix decoder: if no data was pushed, close the output channel

livekit-agents/livekit/agents/utils/codecs/decoder.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,9 @@ def push(self, chunk: bytes):
131131

132132
def end_input(self):
133133
self._input_buf.end_input()
134+
if not self._started:
135+
# if no data was pushed, close the output channel
136+
self._output_ch.close()
134137

135138
def _decode_loop(self):
136139
container: av.container.InputContainer | None = None

0 commit comments

Comments
 (0)