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,8 +216,12 @@ 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) {
-				continue
+			if errors.Is(err, redis.Nil) || retry.Retryable(err) {
+				select {
+				case <-ctx.Done():
+				default:
+					continue
+				}
 			}
 
 			return streams, WrapCmdErr(cmd)