From 137c6ab6447513f182d68e65091d799aa4357e3d Mon Sep 17 00:00:00 2001 From: mkelvers Date: Sun, 5 Jul 2026 23:25:17 +0200 Subject: [PATCH] test: use wg.Go in concurrent resolve test --- internal/playback/source_cache_test.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/internal/playback/source_cache_test.go b/internal/playback/source_cache_test.go index aa4b6760..b7fd3485 100644 --- a/internal/playback/source_cache_test.go +++ b/internal/playback/source_cache_test.go @@ -69,11 +69,9 @@ func TestResolveStreamResultCollapsesConcurrentMisses(t *testing.T) { results := make(chan *domain.StreamResult, requests) var wg sync.WaitGroup for range requests { - wg.Add(1) - go func() { - defer wg.Done() + wg.Go(func() { results <- svc.resolveStreamResult(context.Background(), 42, nil, "3", "sub", false, false) - }() + }) } <-started close(release)