n2, e2 := io.ReadFull(r2, b2)
		if n1 != n2 {
			return false, fmt.Sprintf("Read %d != %d bytes from the readers", n1, n2)
		}
		if !bytes.Equal(b1[:n1], b2[:n2]) {
			return false, fmt.Sprintf("After reading %d equal buffers (32Kib each), we got the following two strings:\n%v\n%v\n",
				i, b1, b2)
		}
		// Check if stream has ended
		if (e1 == io.ErrUnexpectedEOF && e2 == io.ErrUnexpectedEOF) || (e1 == io.EOF && e2 == io.EOF) {

	jsonfmt "github.com/minio/minio/internal/s3select/json"
	"github.com/minio/minio/internal/s3select/jstream"
	"github.com/minio/minio/internal/s3select/sql"
)

// Reader implements reading records from parquet input.
type Reader struct {
	io.Closer
	r *parquetgo.FileReader
}

// NewParquetReader creates a Reader2 from a io.ReadSeekCloser.

        assertEquals(65536, serverData.maxRawSize);
        assertEquals(123456789, serverData.sessionKey);
        assertEquals(SmbConstants.CAP_UNICODE | SmbConstants.CAP_NT_SMBS, serverData.capabilities);
        // readInt2 returns unsigned value, so -480 becomes 65056
        assertEquals(65056, serverData.serverTimeZone);
        assertEquals(8, serverData.encryptionKeyLength);
    }

    @Test

        }

        @Test
        @DisplayName("Test read string with odd Unicode alignment")
        void testReadStringUnicodeAlignment() {
            testBlock.setUseUnicode(true);
            // Test reading Unicode string with alignment

            byte[] buffer = new byte[100];
            // Write "Test" in UTF-16LE directly at position 2 (even offset)

            byte[] parentKeyBytes = new byte[16];
            System.arraycopy(buffer, offset + 32, parentKeyBytes, 0, 16);
            this.parentLeaseKey = new Smb2LeaseKey(parentKeyBytes);
            this.epoch = readInt2(buffer, offset + 48);
        }
    }
    
    public boolean isV2() {
        return parentLeaseKey != null;
    }
}
```

### 4.3 Lease Manager
```java

import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import org.jspecify.annotations.Nullable;

/**
 * A {@link PrimitiveSink} that can compute a hash code after reading the input. Each hasher should
 * translate all multibyte values ({@link #putInt(int)}, {@link #putLong(long)}, etc) to bytes in
 * little-endian order.
 *

But normally you won't have to worry about it, it's done automatically, continue reading. 🤓

///

## Use Cases { #use-cases }

You could use this to stream data from an **AI LLM** service, from **logs** or **telemetry**, or from other types of data that can be structured in **JSON** items.

/// tip

	resp := rw.Result()
	if resp.StatusCode != 123 {
		t.Fatalf("unexpected status: %v", resp.StatusCode)
	}
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		t.Fatalf("reading response body failed: %v", err)
	}
	if string(body) != "hello" {
		t.Fatalf("response body incorrect: %v", string(body))
	}

	// Check that Unwrap works
	if trw.Unwrap() != rw {

	r := rand.New(rand.NewSource(time.Now().UnixNano()))
	randInterval := func() time.Duration {
		return time.Duration(r.Float64() * 5 * float64(time.Second))
	}

	// To avoid all MinIO nodes reading the tier config object at the same
	// time.
	t := time.NewTimer(tierCfgRefresh + randInterval())
	defer t.Stop()
	for {
		select {
		case <-ctx.Done():
			return
		case <-t.C:

     */
    @Override
    protected int readBytesWireFormat(final byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException {
        final int start = bufferIndex;
        final int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
        if (structureSize == 9) {
            return super.readErrorResponse(buffer, bufferIndex);
        }
        if (structureSize != 49) {