diff --git a/internal/output/prefixed.go b/internal/output/prefixed.go index fd2a230570..930008e3bf 100644 --- a/internal/output/prefixed.go +++ b/internal/output/prefixed.go @@ -38,9 +38,13 @@ type prefixWriter struct { prefixed *Prefixed prefix string buff bytes.Buffer + mutex sync.Mutex } func (pw *prefixWriter) Write(p []byte) (int, error) { + pw.mutex.Lock() + defer pw.mutex.Unlock() + n, err := pw.buff.Write(p) if err != nil { return n, err @@ -50,6 +54,9 @@ func (pw *prefixWriter) Write(p []byte) (int, error) { } func (pw *prefixWriter) close() error { + pw.mutex.Lock() + defer pw.mutex.Unlock() + return pw.writeOutputLines(true) }