fix: replace client wait

2025-09-26 19:51:14 +08:00 · 2023-11-12 12:07:14 +08:00
parent 855038c132
commit e65f970097
1 changed files with 2 additions and 1 deletions
--- a/client.go
+++ b/client.go
@@ -91,7 +91,8 @@ func (p *RTSPPuller) Pull() (err error) {
 		p.Error("Play", zap.Error(err))
 		return err
 	}
-	return p.Wait()
+	<-p.Done()
+	return p.Err()
 }

 type RTSPPusher struct {