Function NewInputStream

go/fory/stream.go:35–37

NewInputStream creates a new InputStream that reads from the provided io.Reader. The InputStream owns the buffer and maintains state across sequential Deserialize calls.

(r io.Reader)

// NewInputStream creates a new InputStream that reads from the provided io.Reader.
// The InputStream owns the buffer and maintains state across sequential Deserialize calls.
func NewInputStream(r io.Reader) *InputStream {
	return NewInputStreamWithBufferSize(r, 0)
}

// NewInputStreamWithBufferSize creates a new InputStream with a specified minimum buffer size.
func NewInputStreamWithBufferSize(r io.Reader, bufferSize int) *InputStream {