fix(push): fix tests

Author: ndyakov

commands_test.go

@@ -2948,7 +2948,8 @@ var _ = Describe("Commands", func() {
 
 			res, err = client.HPTTL(ctx, "myhash", "key1", "key2", "key200").Result()
 			Expect(err).NotTo(HaveOccurred())
-			Expect(res[0]).To(BeNumerically("~", 10*time.Second.Milliseconds(), 1))
+			// overhead of the push notification check is about 1-2ms for 100 commands
+			Expect(res[0]).To(BeNumerically("~", 10*time.Second.Milliseconds(), 2))
 		})
 
 		It("should HGETDEL", Label("hash", "HGETDEL"), func() {

redis.go

@@ -1103,9 +1103,9 @@ func (c *baseClient) processPushNotifications(ctx context.Context, cn *pool.Conn
 	// Use WithReader to access the reader and process push notifications
 	// This is critical for hitless upgrades to work properly
 	// NOTE: almost no timeouts are set for this read, so it should not block
-	// longer than necessary, 50us should be plenty of time to read if there are any push notifications
-	// on the socket
-	return cn.WithReader(ctx, 50*time.Microsecond, func(rd *proto.Reader) error {
+	// longer than necessary, 10us should be plenty of time to read if there are any push notifications
+	// on the socket. Even if it was not enough time, the next read will just read the push notifications again.
+	return cn.WithReader(ctx, 10*time.Microsecond, func(rd *proto.Reader) error {
 		// Create handler context with client, connection pool, and connection information
 		handlerCtx := c.pushNotificationHandlerContext(cn)
 		return c.pushProcessor.ProcessPendingNotifications(ctx, handlerCtx, rd)