适配引擎4.9.3

This commit is contained in:
dexter
2022-12-19 09:06:17 +08:00
parent 3cbf22576b
commit 1f3f4bfb0e
3 changed files with 69 additions and 13 deletions

View File

@@ -49,9 +49,9 @@ func (p *RTSPPuller) Connect() error {
return nil
}
func (p *RTSPPuller) Pull() {
func (p *RTSPPuller) Pull() (err error) {
u, _ := url.Parse(p.RemoteURL)
if _, err := p.Options(u); err != nil {
if _, err = p.Options(u); err != nil {
p.Error("Options", zap.Error(err))
return
}
@@ -68,6 +68,7 @@ func (p *RTSPPuller) Pull() {
return
}
p.Wait()
return
}
type RTSPPusher struct {