Function TestReader_ReadStringInto_Large

internal/proto/reader_test.go:350–373

(t *testing.T)

}

func TestReader_ReadStringInto_Large(t *testing.T) {
	// Payload deliberately larger than the default bufio buffer (32 KiB)
	// so we exercise the path where bufio.Reader drains its internal
	// buffer first and then reads remaining bytes directly into buf.
	const size = proto.DefaultBufferSize * 4
	payload := bytes.Repeat([]byte{'a'}, size)
	src := make([]byte, 0, size+32)
	src = append(src, []byte(fmt.Sprintf("$%d\r\n", size))...)
	src = append(src, payload...)
	src = append(src, '\r', '\n')

	r := proto.NewReader(bytes.NewReader(src))
	buf := make([]byte, size)
	n, err := r.ReadStringInto(buf)
	if err != nil {
		t.Fatalf("ReadStringInto: %v", err)
	}
	if n != size {
		t.Fatalf("n = %d, want %d", n, size)
	}
	if !bytes.Equal(buf[:n], payload) {
		t.Fatal("payload mismatch")
	}
}