((netdfs.DfsEnumArray1) info.e).s = new netdfs.DfsInfo1[1];
        ((netdfs.DfsEnumArray1) info.e).s[0] = new netdfs.DfsInfo1();
        ((netdfs.DfsEnumArray1) info.e).s[0].entry_path = "encoded_path";

        NdrLong totalentries = new NdrLong(5);

        netdfs.NetrDfsEnumEx enumEx = new netdfs.NetrDfsEnumEx(dfsName, level, prefmaxlen, info, totalentries);

  assertEquals("/v1/chat/messages/", request1.getUrl().encodedPath());
  assertNotNull(request1.getHeaders().get("Authorization"));

  RecordedRequest request2 = server.takeRequest();
  assertEquals("/v1/chat/messages/2", request2.getUrl().encodedPath());

  RecordedRequest request3 = server.takeRequest();
  assertEquals("/v1/chat/messages/3", request3.getUrl().encodedPath());

  // Shut down the server. Instances cannot be reused.

            // Verify path encoding (UTF-16LE)
            byte[] pathBytes = path.getBytes(StandardCharsets.UTF_16LE);
            byte[] encodedPath = new byte[pathBytes.length];
            bb.get(encodedPath);
            assertArrayEquals(pathBytes, encodedPath);

            // Verify null terminator
            assertEquals(0, bb.getShort());
        }

        @Test

          |
          |
          """.trimMargin(),
        ).setHeader("content-type", "text/event-stream")
        .build(),
    )
    val source = newEventSource()
    assertThat(source.request().url.encodedPath).isEqualTo("/")
    listener.assertOpen()
    listener.assertEvent(null, null, "hey")
    listener.assertClose()
  }

  @RetryingTest(5)
  fun cancelInEventShortCircuits() {
    server.enqueue(

    private static final byte[] BINARY_DATA = ORIGINAL.getBytes();

    private static final String ENCODED_DATA = "aG93IG5vdyBicm93biBjb3cNCg==";

    /**
     * @throws Exception
     */
    public void testEncode() throws Exception {
        assertEquals("1", ENCODED_DATA, Base64Util.encode(BINARY_DATA));
        System.out.println(Base64Util.encode(new byte[] { 'a', 'b', 'c' }));
    }

    /**

    val password: String = httpUrl.password
    val host: String = httpUrl.host
    val port: Int = httpUrl.port
    val pathSize: Int = httpUrl.pathSize
    val encodedPath: String = httpUrl.encodedPath
    val encodedPathSegments: List<String> = httpUrl.encodedPathSegments
    val pathSegments: List<String> = httpUrl.pathSegments
    val encodedQuery: String? = httpUrl.encodedQuery

    client =
      client
        .newBuilder()
        .addInterceptor(
          Interceptor { chain: Interceptor.Chain ->
            if (chain.request().url.encodedPath == "/b") {
              val requestA =
                Request
                  .Builder()
                  .url(server.url("/a"))
                  .build()

    assertThat(response.body.string()).isEqualTo("This is the new location!")
    val request1 = server.takeRequest()
    assertThat(request1.url.encodedPath).isEqualTo("/")
    val request2 = server.takeRequest()
    assertThat(request2.url.encodedPath).isEqualTo("/foo")
  }

  @Test
  fun readAfterLastByte() {
    server.enqueue(MockResponse(body = "ABC"))

    assertThat(connect.headers["Proxy-Authorization"]).isEqualTo(credential)
    assertThat(connect.url.encodedPath).isEqualTo("/")
    val get = server.takeRequest()
    assertThat(get.method).isEqualTo("GET")
    assertThat(get.headers["Proxy-Authorization"]).isNull()
    assertThat(get.url.encodedPath).isEqualTo("/foo")
  }

  @Test
  fun preemptiveThenReactiveProxyAuthentication() {

	public static final fun defaultPort (Ljava/lang/String;)I
	public final fun encodedFragment ()Ljava/lang/String;
	public final fun encodedPassword ()Ljava/lang/String;
	public final fun encodedPath ()Ljava/lang/String;
	public final fun encodedPathSegments ()Ljava/util/List;
	public final fun encodedQuery ()Ljava/lang/String;
	public final fun encodedUsername ()Ljava/lang/String;