diff --git a/internal/core/hls_muxer.go b/internal/core/hls_muxer.go index 1d755672..ed10ab05 100644 --- a/internal/core/hls_muxer.go +++ b/internal/core/hls_muxer.go @@ -398,7 +398,7 @@ func (m *hlsMuxer) runInner(innerCtx context.Context, innerReady chan struct{}) if !m.hlsAlwaysRemux && time.Since(t) >= closeAfterInactivity { m.ringBuffer.Close() <-writerDone - return nil + return fmt.Errorf("not used anymore") } case err := <-writerDone: @@ -407,7 +407,7 @@ func (m *hlsMuxer) runInner(innerCtx context.Context, innerReady chan struct{}) case <-innerCtx.Done(): m.ringBuffer.Close() <-writerDone - return nil + return fmt.Errorf("terminated") } } }