Use iterators

sync/README.md

@@ -13,7 +13,7 @@ SetIf(key K, newValue V, cond Condition) (actual V, ok bool)
 Delete(key K)
 DeleteIf(key K, cond Condition) bool
 Clear()
-All(yield func(key K, value V) bool) bool
+All() iter.Seq2[K, V]
 ```
 
 **Safer waitgroup**

sync/go.mod

@@ -1,3 +1,3 @@
 module github.com/Zamony/go/sync
 
-go 1.21
+go 1.23

sync/hatmap/map.go

@@ -2,7 +2,10 @@
 // It is implemented as an ordinary map protected by mutex ("mutex hat" idiom).
 package hatmap
 
-import "sync"
+import (
+	"iter"
+	"sync"
+)
 
 // Condition to operate on a current value by the given key.
 // May be called multiple times.
@@ -119,15 +122,15 @@ func (m *Map[K, V]) Clear() {
 }
 
 // All iterates over a map.
-func (m *Map[K, V]) All(yield func(K, V) bool) bool {
-	m.mu.RLock()
-	defer m.mu.RUnlock()
-
-	for k, v := range m.data {
-		if !yield(k, v) {
-			return false
+func (m *Map[K, V]) All() iter.Seq2[K, V] {
+	return func(yield func(K, V) bool) {
+		m.mu.RLock()
+		defer m.mu.RUnlock()
+
+		for k, v := range m.data {
+			if !yield(k, v) {
+				return
+			}
 		}
 	}
-
-	return true
 }

sync/hatmap/map_test.go

@@ -86,11 +86,9 @@ func TestMapForEach(t *testing.T) {
 	m.Set("c", 3)
 
 	mit := map[string]int{}
-	completed := m.All(func(key string, value int) bool {
+	for key, value := range m.All() {
 		mit[key] = value
-		return true
-	})
-	equal(t, completed, true)
+	}
 	equal(t, mit, map[string]int{
 		"a": 1,
 		"b": 2,
@@ -134,9 +132,9 @@ func TestMapConcurrent(t *testing.T) {
 			})
 		})
 		goGroup(&wg, func() {
-			m.All(func(string, int) bool {
-				return true
-			})
+			for k, v := range m.All() {
+				_, _ = k, v
+			}
 		})
 	}
 }