We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 87e9c17 commit 4bda9fcCopy full SHA for 4bda9fc
livekit-rtc/livekit/rtc/data_stream.py
@@ -64,7 +64,6 @@ def __init__(
64
attachments=list(header.text_header.attached_stream_ids),
65
)
66
self._queue: asyncio.Queue[proto_DataStream.Chunk | None] = asyncio.Queue()
67
- self._chunks: Dict[int, proto_DataStream.Chunk] = {}
68
69
async def _on_chunk_update(self, chunk: proto_DataStream.Chunk):
70
await self._queue.put(chunk)
0 commit comments