diff --git a/internal/staticsources/srt/source.go b/internal/staticsources/srt/source.go index f8aa4b97..a1bf09c1 100644 --- a/internal/staticsources/srt/source.go +++ b/internal/staticsources/srt/source.go @@ -111,6 +111,8 @@ func (s *Source) runReader(sconn srt.Conn) error { return res.Err } + defer s.Parent.SetNotReady(defs.PathSourceStaticSetNotReadyReq{}) + stream = res.Stream for {