From a0cca4d1521f712890cc3c151454c3de3dbba7ab Mon Sep 17 00:00:00 2001 From: langhuihui <178529795@qq.com> Date: Wed, 9 Oct 2024 09:06:55 +0800 Subject: [PATCH] fix: publish lost not shutdown --- stream.go | 6 ------ 1 file changed, 6 deletions(-) diff --git a/stream.go b/stream.go index 3c63f41..ead0168 100644 --- a/stream.go +++ b/stream.go @@ -492,16 +492,10 @@ func (s *Stream) run() { s.Warn("no tracks") if time.Since(s.StartTime) > timeout { lost = true - s.action(ACTION_CLOSE) - continue } } else if s.Publisher != nil && s.Publisher.IsClosed() { s.Warn("publish is closed", zap.Error(context.Cause(s.publisher)), zap.String("ptr", fmt.Sprintf("%p", s.publisher.Context))) lost = true - if len(s.Tracks.Audio)+len(s.Tracks.Video) == 0 { - s.action(ACTION_CLOSE) - continue - } } } if lost {