Requested changes

compparallel.go

@@ -156,9 +156,6 @@ func getValueOrErrorParallel[T any](
 			defer tim.Stop()
 			select {
 			case <-ctx.Done():
-				if !r.IgnoreError {
-					errCh <- ctx.Err()
-				}
 			case <-tim.C:
 				ctx, cancel := context.WithTimeout(ctx, r.Timeout)
 				defer cancel()
@@ -314,13 +311,11 @@ func getChannelOrErrorParallel[T any](
 
 	select {
 	case err, ok := <-errCh:
-		cancelAll()
 		if !ok {
 			return nil, routing.ErrNotFound
 		}
 		return nil, err
 	case <-ctx.Done():
-		cancelAll()
 		return nil, ctx.Err()
 	default:
 		return outCh, nil

compsequential.go

@@ -3,7 +3,6 @@ package routinghelpers
 import (
 	"context"
 	"errors"
-	"sync"
 	"sync/atomic"
 
 	"github.com/ipfs/go-cid"
@@ -204,10 +203,7 @@ func getChannelOrErrorSequential[T any](
 		chans = append(chans, rch)
 	}
 
-	var wg sync.WaitGroup
-	wg.Add(1)
 	go func() {
-		defer wg.Done()
 		for i := 0; i < len(chans); i++ {
 			if chans[i] == nil {
 				cancels[i]()
@@ -229,10 +225,7 @@ func getChannelOrErrorSequential[T any](
 
 			cancels[i]()
 		}
-	}()
 
-	go func() {
-		wg.Wait()
 		close(chanOut)
 	}()