mirror of
https://github.com/Monibuca/plugin-rtsp.git
synced 2025-09-27 03:56:08 +08:00
🐛 FIX: 关闭流后断开rtsp拉流或者推流连接
This commit is contained in:
@@ -45,6 +45,7 @@ func (p *RTSPPuller) Connect() error {
|
|||||||
if err = p.Client.Start(u.Scheme, u.Host); err != nil {
|
if err = p.Client.Start(u.Scheme, u.Host); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
p.SetIO(p.Client)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -107,6 +108,7 @@ func (p *RTSPPusher) Connect() error {
|
|||||||
p.Error("Client.Start", zap.Error(err))
|
p.Error("Client.Start", zap.Error(err))
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
p.SetIO(p.Client)
|
||||||
_, err = p.Client.Options(u)
|
_, err = p.Client.Options(u)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user