}

        // Walk from newest turn to oldest, selecting contiguous newest turns that fit within budget
        int remaining = budgetChars;
        int firstIncludedTurn = turns.size();
        for (int t = turns.size() - 1; t >= 0; t--) {
            final int[] turn = turns.get(t);
            int turnLen = 0;
            for (int i = turn[0]; i < turn[1]; i++) {

        final List<LlmMessage> history = new ArrayList<>();
        history.add(LlmMessage.user("Q1")); // standalone turn (2)
        history.add(LlmMessage.user("Q2")); // 2
        history.add(LlmMessage.assistant("A2")); // pair turn (4)
        history.add(LlmMessage.user("Q3")); // standalone turn (2)
        final LlmChatRequest request = new LlmChatRequest();
        client.testAddHistoryWithBudget(request, history, 100);

  static <T> TypeToken<? extends T> toGenericType(Class<T> cls) {
    if (cls.isArray()) {
      Type arrayOfGenericType =
          Types.newArrayType(
              // If we are passed with int[].class, don't turn it to GenericArrayType
              toGenericType(cls.getComponentType()).runtimeType);
      @SuppressWarnings("unchecked") // array is covariant

)

const (
	testDefaultTimeout = 30 * time.Second
)

// API suite container for IAM
type TestSuiteIAM struct {
	TestSuiteCommon

	ServerTypeDescription string

	// Flag to turn on tests for etcd backend IAM
	withEtcdBackend bool

	endpoint string
	adm      *madmin.AdminClient
	client   *minio.Client
}

func newTestSuiteIAM(c TestSuiteCommon, withEtcdBackend bool) *TestSuiteIAM {

  TF_DeleteTensor(t);
  EXPECT_EQ(2, product[0]);
  EXPECT_EQ(4, product[1]);
  EXPECT_EQ(6, product[2]);
  EXPECT_EQ(8, product[3]);

  // When we turn on grappler, confirm that the tf.Add has been rewritten into a
  // tf.Mul.
  // This capability of checking the executed op names is currently only enabled
  // for TFRT debug build, for performance and simplicity reasons.