Method Write

testutil/wait_buffer.go:38–50

Write implements io.Writer. It is safe for concurrent use.

(p []byte)

// Write implements io.Writer. It is safe for concurrent use.
func (wb *WaitBuffer) Write(p []byte) (int, error) {
	wb.mu.Lock()
	defer wb.mu.Unlock()

	n, err := wb.buf.Write(p)
	s := wb.buf.String()
	for _, w := range wb.waiters {
		if w.cond(s) {
			w.once.Do(func() { close(w.ch) })
		}
	}
	return n, err
}

// WaitFor blocks until the accumulated output contains signal or
// ctx expires. Returns nil on match, ctx.Err() on timeout.