}

    private void writeLittleEndianInt(DataOutputStream dos, int value) throws IOException {
        dos.writeInt(Integer.reverseBytes(value));
    }

    private void writeLittleEndianLong(DataOutputStream dos, long value) throws IOException {
        dos.writeLong(Long.reverseBytes(value));
    }

    @Test
    @DisplayName("Test parsing with invalid data size")
    void testInvalidDataSize() {

    @Test
    @DisplayName("writeBytesWireFormat should write correct structure")
    void testWriteBytesWireFormat() {
        byte[] buffer = new byte[256];
        int offset = 64; // Start at offset to test proper indexing

        int written = request.writeBytesWireFormat(buffer, offset);

        // Verify bytes written
        assertEquals(24, written);

        // Verify structure size (should be 24)

    StringBuilder builder = new StringBuilder();
    Writer writer = new AppendableWriter(builder);

    writer.write("Hello".toCharArray());
    writer.write(',');
    writer.write(0xBEEF0020); // only lower 16 bits are important
    writer.write("Wo");
    writer.write("Whirled".toCharArray(), 3, 2);
    writer.write("Mad! Mad, I say", 2, 2);

    assertEquals("Hello, World!", builder.toString());
  }

        public XmlWriterRequestBuilder<T> writer(Writer writer) {
            this.writer = writer;
            return this;
        }

        public XmlWriterRequestBuilder<T> content(T content) {
            this.content = content;
            return this;
        }

        public XmlWriterRequestBuilder<T> inputLocationFormatter(Function<Object, String> inputLocationFormatter) {

HSPLokio/Buffer;->write(Lokio/Buffer;J)V
HSPLokio/Buffer;->write(Lokio/ByteString;)Lokio/Buffer;
HSPLokio/Buffer;->write([B)Lokio/Buffer;
HSPLokio/Buffer;->write([BII)Lokio/Buffer;
HSPLokio/Buffer;->writeAll(Lokio/Source;)J
HSPLokio/Buffer;->writeByte(I)Lokio/Buffer;
HSPLokio/Buffer;->writeByte(I)Lokio/BufferedSink;
HSPLokio/Buffer;->writeInt(I)Lokio/Buffer;

        Arrays.fill(dst, (byte) 0x55);

        // Act
        int written = enc.encode(dst, dstIndex);

        // Assert: reported written bytes matches size() and requested len.
        assertEquals(len, enc.size(), "size() must equal provided length");
        assertEquals(len, written, "encode() must return number of bytes written");

        // Assert: copied region equals the source slice.

        byte[] minBuffer = new byte[2];
        int written = trans2QueryFSInfo.writeSetupWireFormat(minBuffer, 0);
        assertEquals(2, written);

        // Test with exact parameter size
        byte[] paramBuffer = new byte[2];
        written = trans2QueryFSInfo.writeParametersWireFormat(paramBuffer, 0);
        assertEquals(2, written);

        // Test with zero-length data buffer

        }
        return len;
    }

    /**
     * Writes the AndX wire format to buffer
     * @param dst the destination buffer
     * @param dstIndex the starting index
     * @return the number of bytes written
     */
    protected int writeAndXWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;

    override fun contentType() = delegate.contentType()

    override fun isDuplex() = true

    override fun writeTo(sink: BufferedSink) {
      executorService.schedule({
        try {
          delegate.writeTo(sink)
          sink.close()
        } catch (e: IOException) {
          throw RuntimeException(e)
        }
      }, delayMillis, TimeUnit.MILLISECONDS)

        byte[] dst = new byte[10];

        // writeSetupWireFormat writes 4 bytes:
        // - subCommand byte
        // - 3 zero bytes (padding and no FID)
        int written = pipe.writeSetupWireFormat(dst, 0);

        assertEquals(4, written, "Setup should write 4 bytes");
        assertEquals(SmbComTransaction.TRANS_WAIT_NAMED_PIPE, dst[0], "First byte should be subCommand");