replaceWith =
      ReplaceWith(
        expression = "response.processEventSource(listener)",
        imports = ["okhttp3.sse.EventSource.Companion.processEventSource"],
      ),
    level = DeprecationLevel.WARNING,
  )
  @JvmStatic
  fun processResponse(
    response: Response,
    listener: EventSourceListener,
  ): Unit = response.processEventSource(listener)

            CreateContextResponse response = mock(CreateContextResponse.class);
            when(response.getName()).thenReturn(expectedName);

            byte[] actualName = response.getName();
            assertArrayEquals(expectedName, actualName);
            verify(response, times(1)).getName();
        }

        @Test

    val response = call.execute()

    // Body contains nothing.
    assertThat(response.body.bytes().size).isEqualTo(0)
    assertThat(response.body.contentLength()).isEqualTo(0)

    // Content-Length header doesn't exist in a 204 response.
    assertThat(response.header("content-length")).isNull()
    assertThat(response.code).isEqualTo(204)
    val request = server.takeRequest()

    call.execute().use { response ->
      assertThat(
        response.body.string(),
      ).isEqualTo("unrelated response body!")
    }
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    // No connection reuse.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    for (response in responsesNotClosed) {
      response!!.closeQuietly()
    }
  }

        assertEquals(b, response.b);
        assertEquals(0, response.off);
    }

    @Test
    public void testSetParam() {
        byte[] b = new byte[0];
        response.setParam(b, 0);
        assertEquals(b, response.b);
        assertEquals(0, response.off);
    }

    @Test
    public void testWriteParameterWordsWireFormat() {
        assertEquals(0, response.writeParameterWordsWireFormat(new byte[0], 0));
    }

        .url("http://publicobject.com/secrets/hellosecret.txt")
        .build();

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

      System.out.println(response.body().string());
    }
  }

  public static void main(String... args) throws Exception {
    new Authenticate().run();
  }

    val request = Request(server.url("/"))

    val response = client.newCall(request).execute()

    response.use {
      assertEquals(200, response.code)
      assertEquals(TlsVersion.TLS_1_3, response.handshake?.tlsVersion)
      assertEquals(Protocol.HTTP_2, response.protocol)

      assertThat(response.exchangeAccessor!!.connectionAccessor.socket())
        .isInstanceOf<SSLSocketImpl>()
    }

    val webSocket: WebSocket,
    val response: Response,
  )

  internal class Failure(
    val t: Throwable,
    val response: Response?,
  ) {
    val responseBody: String? =
      when {
        response != null && response.code != 101 -> response.body.string()
        else -> null
      }

    override fun toString(): String =
      when (response) {
        null -> "Failure[$t]"

        serverData.encryptionKeyLength = 8;
        response.flags2 = ServerMessageBlock.FLAGS2_UNICODE;
        byte[] domainNameBytes = "DOMAIN_U".getBytes("UTF-16LE");
        response.byteCount = 8 + domainNameBytes.length + 2; // key + domain + null terminator

        // Prepare byte array
        byte[] encryptionKey = "12345678".getBytes();
        ByteBuffer buffer = ByteBuffer.allocate(response.byteCount);
        buffer.put(encryptionKey);

import org.codelibs.fess.dict.kuromoji.KuromojiFile;
import org.codelibs.fess.dict.kuromoji.KuromojiItem;
import org.lastaflute.web.Execute;
import org.lastaflute.web.response.JsonResponse;
import org.lastaflute.web.response.StreamResponse;

import jakarta.annotation.Resource;

/**
 * API action for admin Kuromoji dictionary management.