codec/wrappers/closers.go

// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
// See the file LICENSE for licensing terms.

package wrappers

import (
	"io"
	"sync"
)

// Closer is a nice utility for closing a group of objects while reporting an
// error if one occurs.
type Closer struct {
	lock    sync.Mutex
	closers []io.Closer
}

// Add a new object to be closed.
func (c *Closer) Add(closer io.Closer) {
	c.lock.Lock()
	defer c.lock.Unlock()

	c.closers = append(c.closers, closer)
}

// Close closes each of the closers add to [c] and returns the first error
// that occurs or nil if no error occurs.
func (c *Closer) Close() error {
	c.lock.Lock()
	closers := c.closers
	c.closers = nil
	c.lock.Unlock()

	errs := Errs{}
	for _, closer := range closers {
		errs.Add(closer.Close())
	}
	return errs.Err
}