diff --git a/puller.go b/puller.go index e87ba2f..00e79c3 100644 --- a/puller.go +++ b/puller.go @@ -85,7 +85,7 @@ func (pub *Puller) startPull(puller IPuller) { } else { if err = puller.Publish(pub.StreamPath, puller); err != nil { puller.Error("pull publish", zap.Error(err)) - return + continue } if stream != puber.Stream { // 老流中的音视频轨道不可再使用