diff --git a/pool.go b/pool.go
index 9093b09..9b2a8b5 100644
--- a/pool.go
+++ b/pool.go
@@ -484,10 +484,8 @@ func (pool *Pool) subMany(
 			hasAuthed := false
 			interval := 3 * time.Second
 			for {
-				select {
-				case <-ctx.Done():
+				if ctx.Err() != nil {
 					return
-				default:
 				}
 
 				var sub *Subscription