Data streams v2 #1985
1egoman
merged
68 commits into
main
from
data-streams-v2
github-advanced-security
commented
on 2026-06-23
xianshijing-lk
commented
on 2026-06-29
lukasIO
approved these changes
on 2026-07-01
refactor: rename constant
def3c980
fix: make rpc use datastream.sendText, NOT streamText
9f467c41
fix: convert rpc tests from streamText -> sendText
632f5519
feat: add initial support for single packet data streams via hacky me…
b90d2eeb
feat: add backwards compatibility back in for old multi packet v1 dat…
cb4a54ad
feat: check all participants in room before broadcasting a v2 data st…
2d7936f3
feat: add initial data stream benchmark app
a18007c6
feat: add missing constants file
578dbd86
feat: add initial data stream compression implementation
7c35a52a
feat: migrate compression to get rid of "pump" and compress per packe…
aac267bb
fix: swap else if -> switch/case
c7acc6be
feat: add initial take at streaming through CompressionStream for data
c406a2e1
feat: commit hand written data streams compression approach
38b2a0cb
feat: try out using fflate to share a single compression stream acros…
3f605f1b
refactor: move to deflate-raw for all compression, move to Compressio…
09e2fa1e
fix: get rid of singleWrite mode on streamText
b8aaf48f
fix: clean up code
fe33ba5f
feat: remove compression from streamText, in practice this doesn't re…
3ca6f5f1
feat: add compression into bytestreams too
e918ca20
refactor: move around outgoing data stream single packet / compressio…
6d092602
fix: reduce needless diff churn
087fe22a
feat: add max header size breaking change
234d378d
feat: advertise new CAP_COMPRESSION_DEFLATE_RAW capability to SFU
f79abfcc
feat: add proper OutgoingDataStreamManager tests
7e342e4b
feat: add initial IncomingDataStreamManager tests
8d9ec441
fix: ensure that compression only used when remote participants suppo…
18fe70ca
fix: fiz zlib Z_SYNC_FLUSH test
1932f777
feat: add a few more IncomingDataStreamManager tests
209e654b
fix: reformat code
82b1f4c4
fix: remove unused import
c744642e
fix: remove Z_SYNC_FLUSH test, it was not really testing the right thing
01dfa70a
fix: add participant disconnect test
bead0543
fix: add sendFile v1 outgoing data stream manager tests
2455a65c
feat: port over data streams implementation to use newly added proto …
33a3ce4c
feat: commit initial data streams spec
5464880c
fix: remove unused tests
a7780dec
fix: remove earlier drafts mention
0611aba0
fix: remove more out of date E2EE stuff and note about utf-8 chunk bo…
78fe0153
fix: update misleading comments
c551b4a6
fix: add sendBytes method as the main entrypoint for sending inline b…
00ba872a
fix: make sendFile optional in spec
cc53c78d
fix: run npm run format
9cc7a282
fix: address remaining lint errors
66f2811a
fix: add missing changeset
72ed4f4c
fix: add log when unknown compression scheme encountered
e4b07a56
fix: convert intermedite streams to transformstream
2b034a71
fix: port compression to use TransformStream
2280836c
feat: add zero length single packet data stream tests
dc69bf74
fix: swap break for return
1536956e
fix: ensure data stream payload will only ever be compressed once
21426e2b
fix: address lint error
7f488819
feat: add name / mimeType to new sendBytes method
b4326850
docs: update CompressedStreamState docstring
1edcb689
feat: add compressedStream.lengthLargerThan to allow for partial stre…
a3ffb95b
Revert "feat: add compressedStream.lengthLargerThan to allow for part…
27f4afdb
refactor: rename CompressedStreamState -> MaybeCollectedStream
9dca376a
feat: adjust progress event to report results more reliably in all co…
4a6e2bb3
fix: address flipped stream controllers check
3d3e26ca
fix: make sure textStreamControllers always cleaned up
f45fadcd
fix: ensure destinationIdentities / compress forwarded along to attac…
2c23c340
feat: add max payload byte size limit to data streams
fc53b239
fix: surface an abnormal data stream trailer close reason as an Abnor…
52734f18
feat: add new test cases for incoming / outgoing data stream handling
902b960d
fix: adjust uint8array cast to get ci to pass
c8e07904
feat: lift NonSharedUint8Array casts further up and use NonSharedUint…
a0e49219
fix: upgrade @livekit/protocol to 1.50.4
0d410373
fix: adjust changeset to minor
f291fd8d
fix: remove data streams spec and benchmark before merging
c3fd1ab7
Assignees
No one assigned
Labels
None yet
Milestone
No milestone
Login to write a write a comment.
Login via GitHub