Fix: Start ByteStreamWriter chunk index at 0 #430 (#431)

5Hyeons · web-flow · commit ac9f3fa4a0b2 · 2025-05-07T11:53:18.000+02:00
diff --git a/livekit-rtc/livekit/rtc/data_stream.py b/livekit-rtc/livekit/rtc/data_stream.py
@@ -340,13 +340,13 @@ async def write(self, data: bytes):
             ]
 
             for chunk in chunked_data:
-                self._next_chunk_index += 1
                 chunk_msg = proto_DataStream.Chunk(
                     stream_id=self._header.stream_id,
                     chunk_index=self._next_chunk_index,
                     content=chunk,
                 )
                 await self._send_chunk(chunk_msg)
+                self._next_chunk_index += 1
 
     @property
     def info(self) -> ByteStreamInfo:

Original file line number	Diff line number	Diff line change
`@@ -340,13 +340,13 @@ async def write(self, data: bytes):`
`340`	`340`	`]`
`341`	`341`
`342`	`342`	`for chunk in chunked_data:`
`343`		`- self._next_chunk_index += 1`
`344`	`343`	`chunk_msg = proto_DataStream.Chunk(`
`345`	`344`	`stream_id=self._header.stream_id,`
`346`	`345`	`chunk_index=self._next_chunk_index,`
`347`	`346`	`content=chunk,`
`348`	`347`	`)`
`349`	`348`	`await self._send_chunk(chunk_msg)`
	`349`	`+ self._next_chunk_index += 1`
`350`	`350`
`351`	`351`	`@property`
`352`	`352`	`def info(self) -> ByteStreamInfo:`