diff --git a/revid/pipeline.go b/revid/pipeline.go index 097978e4..13226ead 100644 --- a/revid/pipeline.go +++ b/revid/pipeline.go @@ -227,7 +227,10 @@ func (r *Revid) setupPipeline(mtsEnc func(dst io.WriteCloser, rate float64) (io. // as a destination. if len(mtsSenders) != 0 { mw := multiWriter(mtsSenders...) - e, _ := mtsEnc(mw, float64(r.cfg.FrameRate)) + e, err := mtsEnc(mw, float64(r.cfg.FrameRate)) + if err != nil { + return err + } encoders = append(encoders, e) }