Merge pull request #242 from alexgridx/harlow-master

Harlow master
2024-10-02 10:08:26 +02:00 · 2024-10-02 10:08:26 +02:00 · 3cca2e079b
commit 3cca2e079b
parent 0ea3954331 d3011ab845
1 changed files with 0 additions and 1 deletions
--- a/consumer.go
+++ b/consumer.go
@ -169,7 +169,6 @@ func (c *Consumer) Scan(ctx context.Context, fn ScanFunc) error {
 			if err != nil {
 				select {
 				case errC <- fmt.Errorf("shard %s error: %w", shardID, err):
-					// first error to occur
 					cancel()
 				default:
 					// error has already occurred