.addInitialSettings("custom.key2", 42)
                .scrollTimeout("100s")
                .searchTimeout("50s")
                .indexTimeout("200s")
                .bulkTimeout("300s")
                .indicesTimeout("150s")
                .clusterTimeout("250s");

        SuggestSettings settings = builder.build(client, id);

        assertNotNull(settings);

  }

  public void testParse_writeExpirationHours() {
    CacheBuilderSpec spec = parse("expireAfterWrite=150h");
    assertThat(spec.writeExpirationTimeUnit).isEqualTo(HOURS);
    assertThat(spec.writeExpirationDuration).isEqualTo(150L);
    assertCacheBuilderEquivalence(
        CacheBuilder.newBuilder().expireAfterWrite(150L, HOURS), CacheBuilder.from(spec));
  }

  public void testParse_writeExpirationMinutes() {

        bufDataStartField.setAccessible(true);
        bufDataStartField.set(response, 0);

        // Prepare buffer with totalParameterCount = 1500
        buffer[bufferIndex] = 0x00;
        buffer[bufferIndex + 1] = 0x00;
        buffer[bufferIndex + 2] = 0x00;
        SMBUtil.writeInt4(1500, buffer, bufferIndex + 3);

        // Fill rest of required fields
        for (int i = 7; i < 37; i++) {

ARGS:
requests_max                    (number)    set the maximum number of concurrent requests (default: 'auto')
cluster_deadline                (duration)  set the deadline for cluster readiness check (default: '10s')
cors_allow_origin               (csv)       set comma separated list of origins allowed for CORS requests (default: '*')

                }
            }

            assertEquals(2, t.numThreads, "Thread count should be 2");
            assertEquals(4, t.numIter, "Iteration count should be 4");
            assertEquals(150L, t.delay, "Delay should be 150");
            assertEquals("smb://test/file.txt", t.url, "URL should be parsed");
        }
    }

    @Test
    @DisplayName("ltime field is mutable")
    void testLtimeField() {

        // Test query frequency
        item.setQueryFreq(200L);
        assertEquals(200L, item.getQueryFreq());

        // Test document frequency
        item.setDocFreq(150L);
        assertEquals(150L, item.getDocFreq());

        // Test user boost
        item.setUserBoost(2.0f);
        assertEquals(2.0f, item.getUserBoost(), 0.001f);

        // Test readings

  /**
   * We delay sending the last byte of the request body 1500 ms. The 1000 ms read timeout should
   * only elapse 1000 ms after the request body is sent.
   */
  @Test
  fun headersReadTimeoutDoesNotStartUntilLastRequestBodyByteFire() {
    enableProtocol(Protocol.HTTP_2)
    server.enqueue(
      MockResponse
        .Builder()
        .headersDelay(1500, TimeUnit.MILLISECONDS)
        .build(),
    )

	10 * time.Millisecond,
	50 * time.Millisecond,
	100 * time.Millisecond,
	250 * time.Millisecond,
	500 * time.Millisecond,
	1000 * time.Millisecond, // 1s
	1500 * time.Millisecond,
	3000 * time.Millisecond,
	5000 * time.Millisecond,
	10000 * time.Millisecond, // 10s
}

// KMS is a connection to a key management system.
// It implements various cryptographic operations,
// like data key generation and decryption.

   * immediately. A stopped service may not be restarted.
   *
   * @return this
   * @throws IllegalStateException if the service is not {@link State#NEW}
   * @since 15.0
   */
  @CanIgnoreReturnValue
  Service startAsync();

  /** Returns {@code true} if this service is {@linkplain State#RUNNING running}. */
  boolean isRunning();

          protected void doStart() {
            super.doStart();
            // This will delay service listener execution at least 150 milliseconds
            Uninterruptibles.sleepUninterruptibly(150, MILLISECONDS);
          }
        };
    Service a =
        new NoOpDelayedService(150) {
          @Override
          protected void doStart() {
            b.startAsync();
            super.doStart();
          }