diff --git a/pool.go b/pool.go
index 93d6bc0..846d176 100644
--- a/pool.go
+++ b/pool.go
@@ -269,6 +269,7 @@ func (pool *SimplePool) subMany(ctx context.Context, urls []string, filters Filt
 						select {
 						case events <- ie:
 						case <-ctx.Done():
+							return
 						}
 					case <-ticker.C:
 						if eose {