// Arrange - generic return type respected
        when(tree.send(request)).thenReturn(response);

        // Act
        CommonServerMessageBlockResponse out = tree.send(request);

        // Assert
        assertSame(response, out);
        verify(tree).send(request);
    }

    @Test
    @DisplayName("send with multiple params returns the stubbed response")

    /** The request being built. */
    protected Req request;

    /**
     * Constructor for RequestBuilder.
     * @param client The OpenSearch client.
     * @param request The request instance.
     */
    public RequestBuilder(final Client client, final Req request) {
        this.client = client;
        this.request = request;
    }

    /**
     * Executes the request.

 *
 * @param <REQ> The type of the request
 * @param <REP> The type of the response, which must extend {@code Result<REQ>}
 * @param request The original request that was processed
 * @param result The result of the request, if successful; may be null if an error occurred
 * @param error Any error that occurred during processing; null if the request was successful
 * @since 4.0.0
 */
@Experimental

    }

    /**
     * Processes a non-streaming chat request.
     *
     * @param request the HTTP request
     * @param response the HTTP response
     * @throws IOException if an I/O error occurs
     */
    protected void processChatRequest(final HttpServletRequest request, final HttpServletResponse response) throws IOException {
        if (!"POST".equalsIgnoreCase(request.getMethod())) {
            if (logger.isDebugEnabled()) {

import jakarta.annotation.Resource;

/**
 * Service class for managing request headers used in web crawling configurations.
 * This service provides CRUD operations for request headers that are applied
 * during web crawling to configure HTTP request behavior.
 *
 */
public class RequestHeaderService {

    /**
     * Behavior for request header database operations.
     */
    @Resource

        ValidateNegotiateInfoRequest request =
                new ValidateNegotiateInfoRequest(DEFAULT_CAPABILITIES, defaultClientGuid, DEFAULT_SECURITY_MODE, defaultDialects);

        byte[] buffer1 = new byte[request.size()];
        byte[] buffer2 = new byte[request.size()];

        request.encode(buffer1, 0);
        request.encode(buffer2, 0);

        assertArrayEquals(buffer1, buffer2);

    // Adapt the request and response into our Request and Response domain model.
    val scheme = if (request.handshake != null) "https" else "http"
    val authority = request.headers["Host"] // Has host and port.
    val fancyRequest =
      Request
        .Builder()
        .url("$scheme://$authority/")
        .headers(request.headers)
        .build()
    val fancyResponse =

    }

    @Test
    @DisplayName("Test createResponse method")
    void testCreateResponse() {
        request = new Smb2QueryInfoRequest(mockConfig);
        request.setInfoType((byte) 0x01);
        request.setFileInfoClass((byte) 0x04);

        Smb2QueryInfoResponse response = request.createResponse(mockContext, request);

        assertNotNull(response);
        verify(mockContext, times(1)).getConfig();
    }

  @Test
  fun defaultConfigIsNoTimeout() {
    val request =
      Request
        .Builder()
        .url(server.url("/"))
        .build()
    val call = client.newCall(request)
    assertThat(call.timeout().timeoutNanos()).isEqualTo(0)
  }

  @Test
  fun configureClientDefault() {
    val request =
      Request
        .Builder()
        .url(server.url("/"))
        .build()

        CIFSContext mockContext = mock(CIFSContext.class);
        when(mockContext.getConfig()).thenReturn(mockConfig);
        Smb2TreeDisconnectRequest request = new Smb2TreeDisconnectRequest(mockConfig);

        // When
        Smb2TreeDisconnectResponse response = request.createResponse(mockContext, request);

        // Then
        assertNotNull(response);
        assertTrue(response instanceof Smb2TreeDisconnectResponse);