gilles/go2rtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
seydx
2025-06-16 09:58:55 +02:00
parent ef318f663e
commit 647b2acf48
1 changed files with 0 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/preload/producer.go → pkg/preload/consumer.go
-11
View File
@@ -51,15 +51,10 @@ func NewPreload(name string, query url.Values) *Preload {
ID: core.NewID(), ID: core.NewID(),
FormatName: "preload", FormatName: "preload",
Medias: medias, 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 { func (p *Preload) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error {
sender := core.NewSender(media, track.Codec) sender := core.NewSender(media, track.Codec)
sender.Handler = func(pkt *rtp.Packet) { 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 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 { func (p *Preload) Start() error {
p.closed.Wait() p.closed.Wait()
return nil return nil