// ## Act ##
        try (CurlResponse response = req.execute()) {
            // ## Assert ##
            assertNotNull(mockHolder[0]);
            assertEquals(3000, mockHolder[0].recordedConnectTimeout);
            assertEquals(5000, mockHolder[0].recordedReadTimeout);
        }
    }

    @Test
    public void test_TimeoutNotSetWhenDefault() throws Exception {
        // ## Arrange ##

        }
        assertEqualsUsingSeed(seed, expected, elements);
      }
    }
  }

  public void testCorrectOrdering_mediumHeapsPollFirst() {
    for (int attempts = 0; attempts < reduceIterationsIfGwt(5000); attempts++) {
      int size = new Random().nextInt(256) + 16;
      ArrayList<Integer> elements = createOrderedList(size);
      List<Integer> expected = ImmutableList.copyOf(elements);

=== ":material-language-kotlin: Kotlin"
    ```kotlin
      private val client = OkHttpClient()

      fun run() {
        val request = Request.Builder()

        keyManager.configureKeyRotation(60000);

        // Test disabling rotation
        keyManager.configureKeyRotation(0);

        // Test reconfiguring
        keyManager.configureKeyRotation(30000);
    }

    @Test
    public void testConcurrentKeyOperations() throws InterruptedException {
        int threadCount = 10;
        int operationsPerThread = 50;

    }

    /**
     * Gets the maximum characters for intent detection history.
     * The default returns 3000. Override in subclasses for provider-specific tuning.
     *
     * @return the maximum characters
     */
    protected int getIntentHistoryMaxChars() {
        return 3000;
    }

    /**
     * Gets the maximum characters for assistant message content in history.

class NameServiceClient implements Runnable {

    static final int DEFAULT_SO_TIMEOUT = 5000;
    static final int DEFAULT_RCV_BUF_SIZE = 576;
    static final int DEFAULT_SND_BUF_SIZE = 576;
    static final int NAME_SERVICE_UDP_PORT = 137;
    static final int DEFAULT_RETRY_COUNT = 2;
    static final int DEFAULT_RETRY_TIMEOUT = 3000;

    static final int RESOLVER_LMHOSTS = 1;
    static final int RESOLVER_BCAST = 2;

    @Test
    public void test_doFilter_differentOrigins() throws Exception {
        String[] origins = { "http://localhost:8080", "https://example.com", "http://subdomain.example.com", "https://example.com:3000" };

        for (String origin : origins) {
            resetMocks(); // Reset for each test
            mockRequest.setHeader("Origin", origin);
            mockRequest.setMethod("GET");

        SMBUtil.writeInt4(-1000, buffer, bufferIndex + 11);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 15);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 19);
        SMBUtil.writeInt4(-5000, buffer, bufferIndex + 23);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 27);
        SMBUtil.writeInt4(0, buffer, bufferIndex + 31);
        buffer[bufferIndex + 35] = (byte) 0x80; // 128 as unsigned

@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public final class TestThread<L> extends Thread implements TearDown {

  private static final long DUE_DILIGENCE_MILLIS = 100;
  private static final long TIMEOUT_MILLIS = 5000;

  private final L lockLikeObject;

  private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>();
  private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>();

## ref: http://kubernetes.io/docs/user-guide/services/
##
service:
  type: ClusterIP
  clusterIP: ~
  port: "9000"
  nodePort: 32000
  loadBalancerIP: ~
  externalIPs: []
  annotations: {}

  ## service.loadBalancerSourceRanges Addresses that are allowed when service is LoadBalancer