MCPcopy Create free account
hub / github.com/apache/fory / ResetWithReader

Method ResetWithReader

go/fory/buffer.go:500–513  ·  view source on GitHub ↗
(r io.Reader, bufferSize int)

Source from the content-addressed store, hash-verified

498}
499
500func (b *ByteBuffer) ResetWithReader(r io.Reader, bufferSize int) {
501 b.readerIndex = 0
502 b.writerIndex = 0
503 b.reader = r
504 if bufferSize <= 0 {
505 bufferSize = 4096
506 }
507 b.bufferSize = bufferSize
508 if cap(b.data) < bufferSize {
509 b.data = make([]byte, 0, bufferSize)
510 } else {
511 b.data = b.data[:0]
512 }
513}
514
515// Reserve ensures buffer has at least n bytes available for writing from current position.
516// Call this before multiple unsafe writes to avoid repeated grow() calls.

Calls

no outgoing calls