mirror of
https://github.com/luxfi/utils.git
synced 2026-10-30 15:13:57 +00:00
zeekay
6e664f1f74
Add wrappers package with Packer, Errs, and Closer types for binary serialization and error handling. These are needed by other Lux packages that were previously importing from vm. Add bimap package for bidirectional maps. Update atomic.go to re-export from standalone atomic module.
40 lines
804 B
Go
40 lines
804 B
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
|
|
}
|