From 6732e726d51b8433a413f81973e6ccd4a9c2848b Mon Sep 17 00:00:00 2001 From: seydx Date: Mon, 16 Jun 2025 00:33:16 +0200 Subject: [PATCH] update preload consumer to handle RTP packets --- pkg/preload/producer.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/preload/producer.go b/pkg/preload/producer.go index 932f5e29..8eb6aec2 100644 --- a/pkg/preload/producer.go +++ b/pkg/preload/producer.go @@ -5,6 +5,7 @@ import ( "strings" "github.com/AlexxIT/go2rtc/pkg/core" + "github.com/pion/rtp" ) type Preload struct { @@ -62,7 +63,10 @@ func (p *Preload) GetMedias() []*core.Media { func (p *Preload) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error { sender := core.NewSender(media, track.Codec) - sender.Bind(track) + sender.Handler = func(pkt *rtp.Packet) { + p.Send += pkt.MarshalSize() + } + sender.HandleRTP(track) p.Senders = append(p.Senders, sender) return nil }