@Test
        @DisplayName("Should always return 0")
        void testReadBytesWireFormat() {
            byte[] buffer = new byte[100];

            int bytesRead = echoRequest.readBytesWireFormat(buffer, 0);

            assertEquals(0, bytesRead);
        }

        @Test
        @DisplayName("Should return 0 regardless of buffer content")
        void testReadBytesWithVariousBufferContent() {

    override val timestampNs: Long,
    override val call: Call,
  ) : CallEvent()

  data class ResponseBodyEnd(
    override val timestampNs: Long,
    override val call: Call,
    val bytesRead: Long,
  ) : CallEvent() {
    override fun closes(event: CallEvent): Boolean = event is ResponseBodyStart && call == event.call
  }

  data class ResponseFailed(
    override val timestampNs: Long,

    void testReadBytesWireFormat() {
        request = new Smb2QueryDirectoryRequest(mockConfig);
        byte[] buffer = new byte[100];

        int bytesRead = request.readBytesWireFormat(buffer, 0);

        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("Test size calculation with different buffer sizes")
    void testSizeCalculationWithDifferentBufferSizes() {

    void testReadBytesWireFormatValid() throws Exception {
        // Given
        byte[] buffer = createValidNegotiateResponseBuffer();

        // When
        int bytesRead = response.readBytesWireFormat(buffer, 0);

        // Then
        assertTrue(bytesRead > 0);
        assertEquals(Smb2Constants.SMB2_NEGOTIATE_SIGNING_REQUIRED, response.getSecurityMode());
        assertEquals(0x0311, response.getDialectRevision());

        request = new Smb2QueryInfoRequest(mockConfig);
        byte[] buffer = new byte[256];

        int bytesRead = request.readBytesWireFormat(buffer, 0);

        // This method should always return 0 as the request doesn't read responses
        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("Test complete flow with all setters")
    void testCompleteFlow() {

        byte[] validBuffer = createValidNegotiateResponseBuffer();

        // Should not throw any exception
        int bytesRead = response.readBytesWireFormat(validBuffer, 0);

        assertTrue(bytesRead > 0);
        assertEquals(0x0302, response.getDialectRevision()); // SMB 3.0.2
        assertTrue(response.getMaxTransactSize() > 0);

    void testReadBytesWireFormat() {
        request = new Smb2CreateRequest(mockConfig, "test.txt");

        byte[] buffer = new byte[1024];
        int bytesRead = request.readBytesWireFormat(buffer, 0);

        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("Test all oplock level constants")
    void testOplockLevelConstants() {

    void testReadBytesWireFormat() {
        // Given
        byte[] buffer = createTestData(256);

        // When
        int bytesRead = request.readBytesWireFormat(buffer, 0);

        // Then
        assertEquals(0, bytesRead);
    }

    @ParameterizedTest

    }
    if (responseBodyBytes != null) {
      val responseBodyEnd: ResponseBodyEnd = listener.removeUpToEvent<ResponseBodyEnd>()
      MatcherAssert.assertThat(
        "response body bytes",
        responseBodyEnd.bytesRead,
        responseBodyBytes,
      )
    } else {
      assertThat(listener.recordedEventTypes()).doesNotContain(ResponseBodyEnd::class)
    }
  }

  private fun greaterThan(value: Long): Matcher<Long?> =

    val inputStream = connection.getInputStream()
    assertThat(inputStream.read()).isEqualTo('a'.code)
    try {
      val byteRead = inputStream.read()
      // OpenJDK behavior: end of stream.
      assertThat(byteRead).isEqualTo(-1)
    } catch (e: ProtocolException) {
      // On Android, HttpURLConnection is implemented by OkHttp v2. OkHttp