Method Drain

pkg/concurrent/buffer.go:54–60

Drain returns the buffered content and resets the buffer atomically.

()

// Drain returns the buffered content and resets the buffer atomically.
func (b *Buffer) Drain() string {
	b.mu.Lock()
	defer b.mu.Unlock()
	s := b.buf.String()
	b.buf.Reset()
	return s
}