From 27240a393a0eebbac03240f1438476b824225a62 Mon Sep 17 00:00:00 2001 From: lukasIO Date: Tue, 14 Oct 2025 16:27:35 +0200 Subject: [PATCH 1/3] Wait for dc buffer status low for all published packets --- src/room/RTCEngine.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/room/RTCEngine.ts b/src/room/RTCEngine.ts index a00e472341..25e136744b 100644 --- a/src/room/RTCEngine.ts +++ b/src/room/RTCEngine.ts @@ -1238,7 +1238,6 @@ export default class RTCEngine extends (EventEmitter as new () => TypedEventEmit }), }, }); - await this.sendDataPacket(packet, DataPacket_Kind.RELIABLE); } @@ -1269,6 +1268,8 @@ export default class RTCEngine extends (EventEmitter as new () => TypedEventEmit const msg = packet.toBinary(); + await this.waitForBufferStatusLow(kind); + const dc = this.dataChannelForKind(kind); if (dc) { if (kind === DataPacket_Kind.RELIABLE) { From 1c2880ed35396a3588d2d18ed0aa33cb7076d51d Mon Sep 17 00:00:00 2001 From: lukasIO Date: Tue, 14 Oct 2025 16:29:04 +0200 Subject: [PATCH 2/3] remove wait from streams --- src/room/data-stream/outgoing/OutgoingDataStreamManager.ts | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/room/data-stream/outgoing/OutgoingDataStreamManager.ts b/src/room/data-stream/outgoing/OutgoingDataStreamManager.ts index 8258a97484..ecf31604b9 100644 --- a/src/room/data-stream/outgoing/OutgoingDataStreamManager.ts +++ b/src/room/data-stream/outgoing/OutgoingDataStreamManager.ts @@ -146,7 +146,6 @@ export default class OutgoingDataStreamManager { // Implement the sink async write(text) { for (const textByteChunk of splitUtf8(text, STREAM_CHUNK_SIZE)) { - await engine.waitForBufferStatusLow(DataPacket_Kind.RELIABLE); const chunk = new DataStream_Chunk({ content: textByteChunk, streamId, @@ -278,7 +277,6 @@ export default class OutgoingDataStreamManager { try { while (byteOffset < chunk.byteLength) { const subChunk = chunk.slice(byteOffset, byteOffset + STREAM_CHUNK_SIZE); - await engine.waitForBufferStatusLow(DataPacket_Kind.RELIABLE); const chunkPacket = new DataPacket({ destinationIdentities, value: { From 61b5626141ef4fc81a44ba6b2cc233179de81fca Mon Sep 17 00:00:00 2001 From: lukasIO Date: Thu, 16 Oct 2025 10:11:39 +0200 Subject: [PATCH 3/3] Create cuddly-ties-tease.md --- .changeset/cuddly-ties-tease.md | 5 +++++ 1 file changed, 5 insertions(+) create mode 100644 .changeset/cuddly-ties-tease.md diff --git a/.changeset/cuddly-ties-tease.md b/.changeset/cuddly-ties-tease.md new file mode 100644 index 0000000000..851c8b40e8 --- /dev/null +++ b/.changeset/cuddly-ties-tease.md @@ -0,0 +1,5 @@ +--- +"livekit-client": patch +--- + +Wait for dc buffer status low for all published packets