diff --git a/internal/exec/exec.go b/internal/exec/exec.go index 4ebe600b..36dacfaa 100644 --- a/internal/exec/exec.go +++ b/internal/exec/exec.go @@ -83,7 +83,12 @@ func handlePipe(url string, cmd *exec.Cmd) (core.Producer, error) { return nil, err } - return magic.Open(r) + prod, err := magic.Open(r) + if err != nil { + _ = r.Close() + } + + return prod, err } func handleRTSP(url, path string, cmd *exec.Cmd) (core.Producer, error) {