fix: close channel if it is not closed

ethersphere · Dec 4, 2023 · 9cd6f19 · 9cd6f19
1 parent 012c8c6
commit 9cd6f19
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/file/redundancy/getter/getter.go b/pkg/file/redundancy/getter/getter.go
@@ -242,7 +242,7 @@ func (g *getter) cautiousStrategy(ctx context.Context) error {
 				return
 			}
 			g.setErasureData(c.pos, ch.Data())
-			if c.pos < len(g.sAddresses) {
+			if c.pos < len(g.sAddresses) && !channelIsClosed(c.wait) {
 				close(c.wait)
 			}
 			retrievedCh <- struct{}{}