// When
        Smb2CancelRequest request = new Smb2CancelRequest(mockConfig, mid, asyncId);
        request.setRequestCredits(credits);
        request.setTid(treeId);

        // Then
        assertEquals(mid, request.getMid(), "MID should be set correctly");
        assertEquals(asyncId, request.getAsyncId(), "AsyncId should be set correctly");
        assertEquals(credits, request.getCredit(), "Credits should be set correctly");

    ```java
      private final OkHttpClient client = new OkHttpClient();

      public void run() throws Exception {
        Request request = new Request.Builder()
            .url("https://publicobject.com/helloworld.txt")
            .build();

        try (Response response = client.newCall(request).execute()) {
          if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

        assertNull(request.body());
    }

    @Test
    public void testProxyMethod() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");
        Proxy proxy = Proxy.NO_PROXY;

        CurlRequest result = request.proxy(proxy);

        assertSame(request, result); // Fluent API
        assertSame(proxy, request.proxy());
    }

    @Test

     * Used to verify token-based authentication for API requests.
     */
    @Resource
    protected AccessTokenService accessTokenService;

    /**
     * HTTP servlet request object providing access to request parameters, headers,
     * and other request-specific information needed for API processing.
     */
    @Resource
    protected HttpServletRequest request;

    /**

     *
     * @param request the HTTP servlet request
     * @return the user code from request parameters, or null if not found or invalid
     */
    protected String getUserCodeFromRequest(final HttpServletRequest request) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final String userCode = request.getParameter(fessConfig.getUserCodeRequestParameter());

  override val socket: Socket
    get() = stream!!

  override fun createRequestBody(
    request: Request,
    contentLength: Long,
  ): Sink = stream!!.sink

  override fun writeRequestHeaders(request: Request) {
    if (stream != null) return

    val hasRequestBody = request.body != null
    val requestHeaders = http2HeadersList(request)
    stream = http2Connection.newStream(requestHeaders, hasRequestBody)

            // Initial setup
            request.setReadLength(1000);
            request.setOffset(500L);
            request.setMinimumCount(100);

            // Update parameters
            request.setReadLength(2000);
            request.setOffset(1000L);
            request.setMinimumCount(200);
            request.setRemainingBytes(3000);
            request.setPadding((byte) 4);

        request.setMaxInputResponse(maxInput);

        assertNotNull(request);
    }

    @Test
    @DisplayName("Test setMaxOutputResponse method")
    void testSetMaxOutputResponse() {
        setupMockConfig();
        Smb2IoctlRequest request = new Smb2IoctlRequest(mockConfig, TEST_CONTROL_CODE);
        int maxOutput = 4096;

        request.setMaxOutputResponse(maxOutput);

        assertNotNull(request);
    }

        assertEquals(1024, request.size());
        assertEquals(Integer.valueOf(5000), request.getOverrideTimeout());

        verify(request, times(1)).isResponseAsync();
        verify(request, times(1)).getNext();
        verify(request, times(1)).split();
        verify(request, times(1)).allowChain(nextRequest);
        verify(request, times(1)).createCancel();
        verify(request, times(1)).size();

        }
      }

    // Make the first request waiting until we get our auth challenge.
    val request = Request(server.url("/"))
    blockingAuthClient.newCall(request).enqueue(callback)
    val response1 = responses.take()
    assertThat(response1).isEqualTo("")
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)