apps/plugin-rtsp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtsp.git synced 2025-09-26 19:51:14 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修复流终止时仍然在拉流的bug

Browse Source
This commit is contained in:
dexter
2021-12-14 14:21:52 +08:00
parent 4895f2ec42
commit 329f93022e
4 changed files with 26 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
client.go
View File

@@ -179,7 +179,7 @@ func (client *RTSPClient) pullStream() {
client.setTracks(tracks)
}
for _, track := range tracks {
if res, err = client.Setup(true, baseURL, track, 0, 0); err != nil {
if res, err = client.Setup(true, track, baseURL, 0, 0); err != nil {
Printf("Setup:%s error:%v", baseURL.String(), err)
return
}
@@ -192,6 +192,14 @@ func (client *RTSPClient) pullStream() {
}
Println(res)
// wait until a fatal error
err = client.Wait()
Printf("Wait:%s error:%v", baseURL.String(), err)
var fatalChan = make(chan error)
go func() {
fatalChan <- client.Wait()
}()
select {
case err := <-fatalChan:
Printf("Wait:%s error:%v", baseURL.String(), err)
case <-client.Done():
Printf("client:%s done", client.URL)
}
}