refactor(concurrency): simplify some waitgroup usage, remove extra wg.Done in wg.Go left in 11af9d1 in io.go

internal/utils/io.go

@@ -95,11 +95,9 @@ func (p BidirectionalPipe) Start() error {
 	var srcErr, dstErr error
 	wg.Go(func() {
 		srcErr = p.pSrcDst.Start()
-		wg.Done()
 	})
 	wg.Go(func() {
 		dstErr = p.pDstSrc.Start()
-		wg.Done()
 	})
 	wg.Wait()
 	return errors.Join(srcErr, dstErr)

internal/utils/ref_count_test.go

@@ -15,9 +15,7 @@ func TestRefCounterAddSub(t *testing.T) {
 
 	rc.Add()
 	for range 2 {
-		wg.Go(func() {
-			rc.Sub()
-		})
+		wg.Go(rc.Sub)
 	}
 
 	wg.Wait()