44"bytes"
55"context"
66"io"
7+ "sync"
78"time"
89
910"golang.org/x/xerrors"
@@ -65,7 +66,7 @@ type TestRun struct {
6566id string
6667runner Runnable
6768
68- logs * bytes. Buffer
69+ logs * syncBuffer
6970done chan struct {}
7071started time.Time
7172duration time.Duration
@@ -87,7 +88,9 @@ func (r *TestRun) FullID() string {
8788// Run executes the Run function with a self-managed log writer, panic handler,
8889// error recording and duration recording. The test error is returned.
8990func (r * TestRun )Run (ctx context.Context ) (err error ) {
90- r .logs = new (bytes.Buffer )
91+ r .logs = & syncBuffer {
92+ buf :new (bytes.Buffer ),
93+ }
9194r .done = make (chan struct {})
9295defer close (r .done )
9396
@@ -132,3 +135,20 @@ func (r *TestRun) Cleanup(ctx context.Context) (err error) {
132135//nolint:revive // we use named returns because we mutate it in a defer
133136return
134137}
138+
139+ type syncBuffer struct {
140+ buf * bytes.Buffer
141+ mut sync.Mutex
142+ }
143+
144+ func (sb * syncBuffer )Write (p []byte ) (n int ,err error ) {
145+ sb .mut .Lock ()
146+ defer sb .mut .Unlock ()
147+ return sb .buf .Write (p )
148+ }
149+
150+ func (sb * syncBuffer )String ()string {
151+ sb .mut .Lock ()
152+ defer sb .mut .Unlock ()
153+ return sb .buf .String ()
154+ }