// 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");

                    request.getGroupId(),
                    request.getArtifactId());
            throw new PluginVersionResolutionException(
                    request.getGroupId(),
                    request.getArtifactId(),
                    request.getRepositorySession().getLocalRepository(),
                    request.getRepositories(),
                    resolvedPluginVersions

        // 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() {

        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;

        PopularWordsRequest request = new PopularWordsRequest();
        request.setIndex("test-index");
        request.addTag("tag1");
        request.addRole("role1");
        request.addField("field1");
        request.addLanguage("ja");
        request.addExcludeWord("exclude");
        request.setQueryFreqThreshold(5);

        assertNotNull(request.buildQuery());
    }

    @Test

  }

  companion object {
    /**
     * Cache control request directives that require network validation of responses. Note that such
     * requests may be assisted by the cache via conditional GET requests.
     */
    @JvmField
    val FORCE_NETWORK = commonForceNetwork()

    /**
     * Cache control request directives that uses the cache only, even if the cached response is

		Credentials auth.Credentials `xml:"Credentials,omitempty"`
	} `xml:"AssumeRoleWithCertificateResult"`
	Metadata struct {
		RequestID string `xml:"RequestId,omitempty"`
	} `xml:"ResponseMetadata,omitempty"`
}

// AssumeRoleWithCustomTokenResponse contains the result of a successful
// AssumeRoleWithCustomToken request.
type AssumeRoleWithCustomTokenResponse struct {

		t.Fatal("Test shouldn't fail for a possible net/rpc request.")
	}
	r = &http.Request{
		Proto:  "HTTP/1.1",
		Method: http.MethodGet,
		URL:    u,
	}
	if !guessIsRPCReq(r) {
		t.Fatal("Test shouldn't fail for a possible net/rpc request.")
	}
	r = &http.Request{
		Proto:  "HTTP/1.1",
		Method: http.MethodGet,
		URL:    &url.URL{Path: grid.RoutePath},
	}
	if !guessIsRPCReq(r) {

          localPort = 80,
        ),
      )
    val requestLine = decodeRequestLine("CONNECT example.com:8080 HTTP/1.1")
    val request = RecordedRequest(requestLine, headers, emptyList(), 0, ByteString.EMPTY, 0, 0, socket)
    assertThat(request.target).isEqualTo("example.com:8080")
    assertThat(request.url.toString()).isEqualTo("http://example.com:8080/")
  }

  @Test fun testAbsoluteForm() {
    val socket =
      MockWebServerSocket(

   * - 2 requests happen concurrently to a host that can be coalesced onto a single connection.
   * - Both request discover no existing connection. They both make a connection.
   * - The first request "wins the race".
   * - The second request discovers it "lost the race" and closes the connection it just opened.
   * - The second request uses the coalesced connection from request1.