new Trans2QueryPathInformationResponse(Trans2QueryPathInformationResponse.SMB_QUERY_FILE_BASIC_INFO) {
                };
        int bytesRead = trans.readDataWireFormat(buffer, 0, buffer.length);
        assertEquals(buffer.length, bytesRead);
        // Access private field 'info'
        java.lang.reflect.Field infoField = Trans2QueryPathInformationResponse.class.getDeclaredField("info");

        byte[] buffer = new byte[100];
        int offset = 10;

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

        // Then
        assertEquals(0, bytesRead, "Cancel requests do not read response data");
    }

    @Test
    @DisplayName("Test multiple property settings")
    void testMultiplePropertySettings() {

        buffer[bufferIndex++] = (byte) 0x80;
        buffer[bufferIndex++] = (byte) 0xFF;
        // encryptionKeyLength
        buffer[bufferIndex++] = 8;

        int bytesRead = response.readParameterWordsWireFormat(buffer, 0);
        assertEquals(34, bytesRead);
        assertEquals(5, response.getDialectIndex());
        assertTrue(response.getServerData().encryptedPasswords);

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

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

        // Then
        assertEquals(0, bytesRead);
    }

    @ParameterizedTest
    @ValueSource(ints = { 0, 10, 50, 100, 200 })
    @DisplayName("Should write consistent structure at different offsets")

        request = new Smb2NegotiateRequest(mockConfig, 0);
        byte[] buffer = new byte[256];

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

        // Then - This is a request, so it doesn't read from wire
        assertEquals(0, bytesRead);
    }

    @ParameterizedTest
    @DisplayName("Should generate correct dialects for version ranges")

                throw new SMBProtocolDecodingException("Test exception");
            }
            return bytesRead;
        }

        public void setBytesWritten(int bytes) {
            this.bytesWritten = bytes;
        }

        public void setBytesRead(int bytes) {
            this.bytesRead = bytes;
        }

        public void setThrowOnRead(boolean throwOnRead) {

  private class CountingSource(
    source: Source,
  ) : ForwardingSource(source) {
    var bytesRead = 0L

    override fun read(
      sink: Buffer,
      byteCount: Long,
    ): Long {
      val result = delegate.read(sink, byteCount)
      if (result == -1L) return -1L
      bytesRead += result
      return result
    }
  }

            paramWordsRead = 10;
            return paramWordsRead;
        }

        @Override
        protected int readBytesWireFormat(byte[] src, int srcIndex) {
            bytesRead = 20;
            return bytesRead;
        }

        @Override
        public boolean isRetainPayload() {
            return retainPayload;
        }

        @Override
        public void setRawPayload(byte[] payload) {

            byte[] buffer = new byte[10];
            int bytesRead = in.read(buffer);
            assertEquals(10, bytesRead, "Should read requested bytes");
            assertEquals("0123456789", new String(buffer, 0, bytesRead, "UTF-8"));

            // Read next chunk
            bytesRead = in.read(buffer);
            assertEquals(10, bytesRead, "Should read next chunk");

            when(mockConfig.isRequireSecureNegotiate()).thenReturn(false);

            // Read the response
            int bytesRead = echoResponse.readBytesWireFormat(buffer, bufferIndex);
            assertEquals(0, bytesRead);

            // Write response (echo responses don't write data)
            int bytesWritten = echoResponse.writeBytesWireFormat(buffer, 0);