From 647b2acf487a36b9d478c8659a6c5f43880f840a Mon Sep 17 00:00:00 2001 From: seydx Date: Mon, 16 Jun 2025 09:58:55 +0200 Subject: [PATCH] cleanup --- pkg/preload/{producer.go => consumer.go} | 11 ----------- 1 file changed, 11 deletions(-) rename pkg/preload/{producer.go => consumer.go} (84%) diff --git a/pkg/preload/producer.go b/pkg/preload/consumer.go similarity index 84% rename from pkg/preload/producer.go rename to pkg/preload/consumer.go index 748dff16..4d3735a8 100644 --- a/pkg/preload/producer.go +++ b/pkg/preload/consumer.go @@ -51,15 +51,10 @@ func NewPreload(name string, query url.Values) *Preload { ID: core.NewID(), FormatName: "preload", Medias: medias, - RemoteAddr: "localhost", }, } } -func (p *Preload) GetMedias() []*core.Media { - return p.Medias -} - func (p *Preload) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error { sender := core.NewSender(media, track.Codec) sender.Handler = func(pkt *rtp.Packet) { @@ -70,12 +65,6 @@ func (p *Preload) AddTrack(media *core.Media, codec *core.Codec, track *core.Rec return nil } -func (p *Preload) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error) { - receiver := core.NewReceiver(media, codec) - p.Receivers = append(p.Receivers, receiver) - return receiver, nil -} - func (p *Preload) Start() error { p.closed.Wait() return nil