clean up changes for lint

Author: stevenlanders

utils/mutex.go

@@ -49,7 +49,7 @@ type atomicWatch[T any] struct {
 }
 
 type AtomicSend[T any] struct {
-	*atomicWatch[T]
+	atomicWatch[T]
 }
 
 // Store updates the value of the atomic watch.
@@ -67,22 +67,21 @@ func (w *AtomicSend[T]) Update(f func(T) (T, bool)) {
 }
 
 func NewAtomicSend[T any](value T) (w AtomicSend[T]) {
-	w.atomicWatch = &atomicWatch[T]{}
 	w.ptr.Store(newVersion(value))
 	// nolint:nakedret
 	return
 }
 
 func (w *AtomicSend[T]) Subscribe() AtomicRecv[T] {
-	return AtomicRecv[T]{w.atomicWatch}
+	return AtomicRecv[T]{&w.atomicWatch}
 }
 
 // AtomicWatch stores a pointer to an IMMUTABLE value.
 // Loading and waiting for updates do NOT require locking.
 // TODO(gprusak): remove mutex and rename to AtomicSend,
 // this will allow for sharing a mutex across multiple AtomicSenders.
 type AtomicWatch[T any] struct {
-	*atomicWatch[T]
+	atomicWatch[T]
 	mu sync.Mutex
 }
 
@@ -98,7 +97,7 @@ func NewAtomicWatch[T any](value T) (w AtomicWatch[T]) {
 
 // Subscribe returns a view-only API of the atomic watch.
 func (w *AtomicWatch[T]) Subscribe() AtomicRecv[T] {
-	return AtomicRecv[T]{w.atomicWatch}
+	return AtomicRecv[T]{&w.atomicWatch}
 }
 
 // Load returns the current value of the atomic watch.
@@ -233,11 +232,3 @@ func (w *Watch[T]) Lock() iter.Seq2[T, *WatchCtrl] {
 		_ = yield(w.val, &w.ctrl)
 	}
 }
-
-// Set updates the value and notifies all watchers
-func (w *Mutex[T]) Set(value T) {
-	newVersion := newVersion(value)
-	w.mu.Lock()
-	defer w.mu.Unlock()
-	w.value = newVersion.value
-}