override fun OkHttpClient.Builder.withOverride(value: Int): OkHttpClient.Builder =
        connectTimeout(value.toLong(), TimeUnit.MILLISECONDS)

      override val nonDefaultValue: Int = 5000

      override val badValue: Int
        get() = 10

      override fun isDefaultValue(value: Int): Boolean = value == 10000
    }

    object ReadTimeoutOverride : Override<Int> {

        .isEqualTo("Code must be in range [1000,5000): 1")
    }
    data.write("88021388".decodeHex()) // Close with code 5000
    assertFailsWith<ProtocolException> {
      clientReader.processNextFrame()
    }.also { expected ->
      assertThat(expected.message)
        .isEqualTo("Code must be in range [1000,5000): 5000")
    }
  }

  @Test fun closeReservedSetThrows() {

   * should yield one sleep for a total delay of 500ms.
   */
  @Test
  fun throttleRequest() {
    assumeNotWindows()
    server.enqueue(
      MockResponse()
        .throttleBody(3, 500, TimeUnit.MILLISECONDS),
    )
    val startNanos = System.nanoTime()
    val connection = server.url("/").toUrl().openConnection()
    connection.setDoOutput(true)

            } catch (IOException e) {
                log.debug("Error closing server socket", e);
            }
        }

        if (serverThread != null) {
            try {
                serverThread.join(5000); // Wait up to 5 seconds
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }

        registrations.clear();

          i++
          keyIndex++
        }
      }
    } while (cursor.next() != -1)
  }

  fun closeCodeExceptionMessage(code: Int): String? =
    if (code < 1000 || code >= 5000) {
      "Code must be in range [1000,5000): $code"
    } else if (code in 1004..1006 || code in 1015..2999) {
      "Code $code is reserved and may not be used."
    } else {
      null
    }

    /**
     * Create a new handle reconnector
     * @param manager the persistent handle manager
     */
    public HandleReconnector(PersistentHandleManager manager) {
        this(manager, 3, 1000);
    }

    /**
     * Create a new handle reconnector with custom settings
     * @param manager the persistent handle manager
     * @param maxRetries maximum number of retry attempts

    ticker.advance(1234567);
    assertThat(stopwatch.toString()).isEqualTo("1.235 ms");
    stopwatch.reset();
    stopwatch.start();
    ticker.advance(5000000000L);
    assertThat(stopwatch.toString()).isEqualTo("5.000 s");
    stopwatch.reset();
    stopwatch.start();
    ticker.advance((long) (1.5 * 60 * 1000000000L));
    assertThat(stopwatch.toString()).isEqualTo("1.500 min");
    stopwatch.reset();
    stopwatch.start();

        this.name = "\\PIPE\\LANMAN";

        this.maxParameterCount = 8;
        this.maxDataCount = 16384;
        this.maxSetupCount = (byte) 0x00;
        this.setupCount = 0;
        this.timeout = 5000;
    }

    @Override
    public void reset(final int key, final String lastN) {
        super.reset();
        this.lastName = lastN;
    }

    @Override

     */
    public long getRetryDelay() {
        switch (severity) {
        case RECOVERABLE:
            return 100; // Immediate retry with small delay
        case TRANSIENT:
            return 5000; // Wait 5 seconds
        default:
            return 0; // No retry
        }
    }

    @Override
    public String toString() {
        StringBuilder sb = new StringBuilder();

        DataStoreException exception = new DataStoreException(message);
        assertEquals(message, exception.getMessage());
        assertTrue(exception.getMessage().length() > 5000);
    }

    @Test
    public void test_getLocalizedMessage() {
        // Test getLocalizedMessage method (inherited from Throwable)
        String message = "Localized error message";