summaryrefslogtreecommitdiff
path: root/vendor/codeberg.org/gruf/go-structr/queue_ctx.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/codeberg.org/gruf/go-structr/queue_ctx.go')
-rw-r--r--vendor/codeberg.org/gruf/go-structr/queue_ctx.go7
1 files changed, 4 insertions, 3 deletions
diff --git a/vendor/codeberg.org/gruf/go-structr/queue_ctx.go b/vendor/codeberg.org/gruf/go-structr/queue_ctx.go
index 766644c3c..3d15e619c 100644
--- a/vendor/codeberg.org/gruf/go-structr/queue_ctx.go
+++ b/vendor/codeberg.org/gruf/go-structr/queue_ctx.go
@@ -73,9 +73,10 @@ func (q *QueueCtx[T]) Debug() map[string]any {
m["indices"] = indices
for i := range q.indices {
var n uint64
- for _, list := range q.indices[i].data {
- n += uint64(list.len)
- }
+ q.indices[i].data.Iter(func(_ string, l *list) (stop bool) {
+ n += uint64(l.len)
+ return
+ })
indices[q.indices[i].name] = n
}
q.mutex.Unlock()