*
     * @param connectTimeout the connection timeout in milliseconds
     * @param readTimeout the read timeout in milliseconds
     * @return this CurlRequest instance
     */
    public CurlRequest timeout(final int connectTimeout, final int readTimeout) {
        this.connectTimeout = connectTimeout;
        this.readTimeout = readTimeout;
        return this;
    }

    /**

        OverrideParam.Dns,
        OverrideParam.HostnameVerifier,
        OverrideParam.Proxy,
        OverrideParam.ProxyAuthenticator,
        OverrideParam.ProxySelector,
        OverrideParam.ReadTimeout,
        OverrideParam.RetryOnConnectionFailure,
        OverrideParam.SocketFactory,
        OverrideParam.SslSocketFactory,
        OverrideParam.WriteTimeout,
        OverrideParam.X509TrustManager,
      ),

        val doReadTimeout = callerIsIdle || doReadTimeout()
        if (doReadTimeout) {
          readTimeout.enter()
        }
        try {
          waitForIo()
        } finally {
          if (doReadTimeout) {
            readTimeout.exitAndThrowIfTimedOut()
          }
        }
      }
      if (headersQueue.isNotEmpty()) {
        return headersQueue.removeFirst()

        // ## Assert ##
        // Default timeout values should be -1 (not set)
        assertEquals(-1, request.connectTimeout);
        assertEquals(-1, request.readTimeout);
    }

    @Test
    public void test_TimeoutSetsValues() {
        // ## Arrange ##
        final CurlRequest request = new CurlRequest(Method.GET, "http://example.com");

        // ## Act ##

    } catch (ignored: IllegalArgumentException) {
    }
    try {
      builder.writeTimeout(Duration.ofNanos(1))
    } catch (ignored: IllegalArgumentException) {
    }
    try {
      builder.readTimeout(Duration.ofNanos(1))
    } catch (ignored: IllegalArgumentException) {
    }
    try {
      builder.callTimeout(Duration.ofDays(365))
    } catch (ignored: IllegalArgumentException) {
    }
    try {

        .url(server.url("/"))
        .post(DelayedRequestBody("hello".toRequestBody(null), 1500, TimeUnit.MILLISECONDS))
        .build()
    client =
      client
        .newBuilder()
        .readTimeout(1000, TimeUnit.MILLISECONDS)
        .build()
    val call = client.newCall(request)
    assertFailsWith<IOException> {
      call.execute()
    }.also { expected ->

 * @param source the source used to read bytes from the socket.
 */
internal fun Socket.isHealthy(source: BufferedSource): Boolean =
  try {
    val readTimeout = soTimeout
    try {
      soTimeout = 1
      !source.exhausted()
    } finally {
      soTimeout = readTimeout
    }
  } catch (_: SocketTimeoutException) {
    true // Read timed out; socket is good.
  } catch (_: IOException) {

    )
    server.enqueue(
      MockResponse
        .Builder()
        .body("DEF")
        .build(),
    )
    val urlConnection = server.url("/").toUrl().openConnection()
    urlConnection!!.readTimeout = 1000
    val inputStream = urlConnection.getInputStream()
    assertThat(inputStream!!.read()).isEqualTo('A'.code)
    assertThat(inputStream.read()).isEqualTo('B'.code)

=== ":material-language-kotlin: Kotlin"
    ```kotlin
      private val client: OkHttpClient = OkHttpClient.Builder()
          .connectTimeout(5, TimeUnit.SECONDS)
          .writeTimeout(5, TimeUnit.SECONDS)
          .readTimeout(5, TimeUnit.SECONDS)
          .callTimeout(10, TimeUnit.SECONDS)
          .build()

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

  private val serverListener = WebSocketRecorder("server")
  private val random = Random(0)
  private var client =
    clientTestRule
      .newClientBuilder()
      .writeTimeout(Duration.ofMillis(500))
      .readTimeout(Duration.ofMillis(500))
      .addInterceptor(
        Interceptor { chain: Interceptor.Chain ->
          val response = chain.proceed(chain.request())
          // Ensure application interceptors never see a null body.