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

@@ -220,6 +220,13 @@ func (c *Client) XReadUntilResult(ctx context.Context, a *redis.XReadArgs) ([]re
 				continue
 			}
 
+			var timeout interface {
+				Timeout() bool
+			}
+			if errors.As(err, &timeout) && timeout.Timeout() && !errors.Is(err, context.DeadlineExceeded) {
+				continue
+			}
+
 			return streams, WrapCmdErr(cmd)
 		}