// Test that the constructor correctly initializes questionName and questionType
        NameQueryRequest request = new NameQueryRequest(mockConfig, mockName);

        assertNotNull(request);
        assertEquals(mockName, request.questionName);
        assertEquals(NameServicePacket.NB, request.questionType);
    }

    @Test
    void testWriteBodyWireFormat() {

    }

    @Test
    @DisplayName("send(Request, varargs) delegates with null response")
    void sendWithRequestVarargsDelegates() throws Exception {
        // Verifies Request<T> overload forwards to the varargs form with a null response
        @SuppressWarnings("unchecked")
        Request<CommonServerMessageBlockResponse> req = mock(Request.class);

import org.lastaflute.web.util.LaRequestUtil;

/**
 * Utility class for web API operations.
 * Provides functionality for setting and retrieving objects from request attributes,
 * error handling, and validation in web API context.
 */
public final class WebApiUtil {

    /**
     * Request attribute key for storing web API exceptions.
     */
    private static final String WEB_API_EXCEPTION = "webApiException";

    /**

        return new GeoInfo(request);
    }

    /**
     * The search request type.
     */
    public enum SearchRequestType {
        /** Search request type. */
        SEARCH,
        /** Admin search request type. */
        ADMIN_SEARCH,
        /** JSON request type. */
        JSON,
        /** GSA request type. */
        GSA,
        /** Suggest request type. */
        SUGGEST;

        RdmaNegotiateRequest request = new RdmaNegotiateRequest();
        request.setMinVersion(0x0100);
        request.setMaxVersion(0x0100);
        request.setCreditsRequested(credits.getInitialCredits());
        request.setPreferredSendSize(maxReceiveSize);
        request.setMaxReceiveSize(maxReceiveSize);
        request.setMaxFragmentedSize(rdmaConnection.maxFragmentedSize);
        

                break;
            }

            if (request != null) {
                log.debug("Resetting request");
                request.reset();
            }
            if (rpath != null) {
                // resolveDfs() and tree.send() modify the request packet.
                // I want to restore it before retrying. request.reset()

    val call1 = localClient.newCall(Request(server.url("/")))

    call1.execute().use { response ->
      assertThat(response.body.string()).isEqualTo("Req1")
      assertThat(response.handshake).isNotNull()
      assertThat(response.protocol == Protocol.HTTP_1_1)
    }

    eventListener.closed = true

    val call2 = localClient.newCall(Request(server.url("/")))

            // try TreeConnectAndX with the request
            // this does not make any sense if we are disconnecting right now
            T chainedResponse = null;
            if (!(request instanceof SmbComTreeDisconnect) && !(request instanceof Smb2TreeDisconnectRequest)) {
                chainedResponse = treeConnect(request, response);
            }

        .body("data: hello\n\n")
        .setHeader("content-type", "text/event-stream")
        .build()
    );
    Request request = new Request.Builder().url(server.url("/")).build();
    CompletableFuture<Void> future = new CompletableFuture<>();
    factory.newEventSource(request, new EventSourceListener() {
      @Override
      public void onOpen(@NotNull EventSource eventSource, @NotNull Response response) {
        try {

import jcifs.Configuration;
import jcifs.internal.CommonServerMessageBlockRequest;
import jcifs.internal.CommonServerMessageBlockResponse;
import jcifs.internal.Request;

/**
 * Base class for SMB2/SMB3 request messages.
 *
 * This abstract class provides common functionality for handling
 * request messages in the SMB2/SMB3 protocol.
 *
 * @author mbechler
 * @param <T>
 *            response type
 */