Break fors correctly

Author: ajnavarro

composable/sequential.go

@@ -50,16 +50,17 @@ func (r *Sequential) FindProvidersAsync(ctx context.Context, cid cid.Cid, count
 			g.Add(1)
 			go func() {
 				defer g.Done()
+			forr:
 				for {
 					select {
 					case <-ctx.Done():
 						return
 					case v, ok := <-rch:
 						if !ok {
-							break
+							break forr
 						}
 						if sentCount >= count {
-							break
+							break forr
 						}
 
 						chanOut <- v
@@ -167,22 +168,25 @@ func (r *Sequential) SearchValue(ctx context.Context, key string, opts ...routin
 
 	go func() {
 		for i := 0; i < len(chans); i++ {
-			defer cancels[i]()
 			if chans[i] == nil {
+				cancels[i]()
 				continue
 			}
 
+		forr:
 			for {
 				select {
 				case <-ctx.Done():
 					return
 				case v, ok := <-chans[i]:
 					if !ok {
-						break
+						break forr
 					}
 					chanOut <- v
 				}
 			}
+
+			cancels[i]()
 		}
 	}()