diff --git a/pkg/media/output.go b/pkg/media/output.go
index 19cfb7a1..1ed17f2d 100644
--- a/pkg/media/output.go
+++ b/pkg/media/output.go
@@ -506,7 +506,7 @@ func (e *Output) start() {
 				return
 			}
 			err = e.writeSample(s)
-			if err != nil && !errors.Is(err, io.EOF) {
+			if err != nil && !e.closed.IsBroken() {
 				// Store the first write error
 				e.pipelineErr.CompareAndSwap(nil, &err)
 			}