redis.Client#XReadUntilResult(): also re-try timeout errors

An XREAD with BLOCK sets a socket timeout of BLOCK+10s.
If reading the response hits that timeout, it's not re-tried due to BLOCK.
Hence, we have to re-ty it by ourselves.

redis/client.go

@@ -216,7 +216,7 @@ func (c *Client) XReadUntilResult(ctx context.Context, a *redis.XReadArgs) ([]re
 		cmd := c.XRead(ctx, a)
 		streams, err := cmd.Result()
 		if err != nil {
-			if errors.Is(err, redis.Nil) {
+			if (errors.Is(err, redis.Nil) || retry.Retryable(err)) && ctx.Err() == nil {
 				continue
 			}