From 552cc1d766c7cca3dbe9b10cc0bc73e7807d7528 Mon Sep 17 00:00:00 2001 From: Denys Smirnov Date: Tue, 29 Jul 2025 18:02:18 +0300 Subject: [PATCH] Go SDK support for stream data messages. --- .changeset/go-sdk-streams.md | 5 +++++ livekit/types.go | 27 +++++++++++++++++++++++++++ 2 files changed, 32 insertions(+) create mode 100644 .changeset/go-sdk-streams.md diff --git a/.changeset/go-sdk-streams.md b/.changeset/go-sdk-streams.md new file mode 100644 index 000000000..4f9f21b43 --- /dev/null +++ b/.changeset/go-sdk-streams.md @@ -0,0 +1,5 @@ +--- +"github.com/livekit/protocol": patch +--- + +Go SDK support for stream data messages. \ No newline at end of file diff --git a/livekit/types.go b/livekit/types.go index 4666d67bf..644b1393b 100644 --- a/livekit/types.go +++ b/livekit/types.go @@ -328,3 +328,30 @@ func (p *ChatMessage) ToProto() *DataPacket { }, } } + +// ToProto implements DataPacket in Go SDK. +func (p *DataStream_Header) ToProto() *DataPacket { + return &DataPacket{ + Value: &DataPacket_StreamHeader{ + StreamHeader: p, + }, + } +} + +// ToProto implements DataPacket in Go SDK. +func (p *DataStream_Chunk) ToProto() *DataPacket { + return &DataPacket{ + Value: &DataPacket_StreamChunk{ + StreamChunk: p, + }, + } +} + +// ToProto implements DataPacket in Go SDK. +func (p *DataStream_Trailer) ToProto() *DataPacket { + return &DataPacket{ + Value: &DataPacket_StreamTrailer{ + StreamTrailer: p, + }, + } +}