doSend(request);
            response.expiration = System.currentTimeMillis() + timeout;
            while (!response.isReceived) {
                wait(timeout);
                timeout = response.expiration - System.currentTimeMillis();
                if (timeout <= 0) {
                    throw new TransportException(name + " timedout waiting for response to " + request);
                }

    }

    @Test
    @DisplayName("Test constructor with name and timeout sets correct fields")
    void testConstructorWithNameAndTimeout() {
        // Test with pipe name and timeout
        String pipeName = "TestPipe";
        long timeout = 5000L;
        FsctlPipeWaitRequest request = new FsctlPipeWaitRequest(pipeName, timeout);

        // Verify size calculation

    }

    /**
     * Sets the scroll timeout.
     * @param timeout The scroll timeout.
     * @return This builder instance.
     */
    public SuggestSettingsBuilder scrollTimeout(final String timeout) {
        timeoutSettings.setScrollTimeout(timeout);
        return this;
    }

    /**
     * Sets the search timeout.
     * @param timeout The search timeout.
     * @return This builder instance.
     */

            this.indexTimeout = timeout;
        }

        /**
         * Sets the bulk timeout.
         * @param timeout The bulk timeout.
         */
        public void setBulkTimeout(final String timeout) {
            this.bulkTimeout = timeout;
        }

        /**
         * Sets the indices timeout.
         * @param timeout The indices timeout.
         */

    }

    /**
     * Gets the timeout for PDF extraction in milliseconds.
     * @return the timeout in milliseconds
     */
    public long getTimeout() {
        return timeout;
    }

    /**
     * Sets the timeout for PDF extraction in milliseconds.
     * @param timeout the timeout in milliseconds
     */
    public void setTimeout(final long timeout) {
        this.timeout = timeout;
    }

      },
    ).hasMessage("timeout too small")
    assertThat(
      assertThrows<IllegalArgumentException> {
        checkDuration(
          "timeout",
          1L + Int.MAX_VALUE.toLong(),
          TimeUnit.MILLISECONDS,
        )
      },
    ).hasMessage("timeout too large")
  }

  @Test
  fun testDurationDuration() {

        return false;
    }

    /**
     * Gets the response timeout for a specific request.
     *
     * @param request the request to get timeout for
     * @return the timeout in milliseconds
     */
    protected abstract int getResponseTimeout(Request request);

    private void loop() {

        .build()
    val call = client.newCall(request)
    call.timeout().timeout(250, TimeUnit.MILLISECONDS)
    assertFailsWith<IOException> {
      call.execute()
    }.also { expected ->
      assertThat(expected.message).isEqualTo("timeout")
      assertThat(call.isCanceled()).isTrue()
    }
  }

  @Test
  fun timeoutWritingRequestWithEnqueue() {
    server.enqueue(MockResponse())
    val request =
      Request

     *
     * @param name the pipe name to wait for
     * @param timeout the timeout value in milliseconds
     */
    public FsctlPipeWaitRequest(final String name, final long timeout) {
        this.nameBytes = name.getBytes(StandardCharsets.UTF_16LE);
        this.timeoutSpecified = true;
        this.timeout = timeout;
    }

    /**
     * {@inheritDoc}
     *

         * @param process The process to monitor.
         * @param timeout The timeout duration in milliseconds.
         */
        public MonitorThread(final Process process, final long timeout) {
            this.process = process;
            this.timeout = timeout;
        }

        /**
         * Runs the monitor thread, sleeping for the timeout duration and terminating the process if needed.
         */