exit BatchedSubManyEose() immediately as the context expires.

I'm not sure about this, but seems to work.
2025-05-31 01:59:30 +02:00 · 2025-04-06 09:40:53 -03:00 · 2025-04-06 09:40:53 -03:00 · 05e2018d3a
commit 05e2018d3a
parent bba332aea6
1 changed files with 2 additions and 1 deletions
--- a/pool.go
+++ b/pool.go
@ -777,9 +777,10 @@ func (pool *SimplePool) BatchedSubManyEose(
 				select {
 				case res <- ie:
 				case <-ctx.Done():
+					wg.Done()
+					return
 				}
 			}
-
 			wg.Done()
 		}(df)
 	}