add Ping operation when get conn from poll to clear unread data in th…

…e conn(if the conn has)

tests/integration/options.go

@@ -1,6 +1,7 @@
 package pika_integration
 
 import (
+	"context"
 	"time"
 
 	"github.com/redis/go-redis/v9"
@@ -41,5 +42,11 @@ func PikaOption(addr string) *redis.Options {
 		MaxRetries:   -1,
 		PoolSize:     30,
 		PoolTimeout:  60 * time.Second,
+		OnConnect: func(ctx context.Context, cn *redis.Conn) error {
+			// Attempt to clear any unread data (if possible)
+			// Note: Redis does not provide a direct "clear buffer" command, so we simulate it by pinging
+			_, err := cn.Ping(ctx).Result()
+			return err
+		},
 	}
 }