Skip to content

Commit 8db05c2

Browse files
committed
fix chunk size
1 parent 758060a commit 8db05c2

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

livekit-rtc/livekit/rtc/data_stream.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,10 @@ def __init__(
305305
)
306306

307307
async def write(self, data: bytes):
308-
chunked_data = [data[i : i + 2] for i in range(0, len(data), 2)]
308+
chunked_data = [
309+
data[i : i + STREAM_CHUNK_SIZE]
310+
for i in range(0, len(data), STREAM_CHUNK_SIZE)
311+
]
309312

310313
for chunk in chunked_data:
311314
self._next_chunk_index += 1

0 commit comments

Comments
 (0)