reader_skip.go

package avro

// SkipNBytes skips the given number of bytes in the reader.
func (r *Reader) SkipNBytes(n int) {
	read := 0
	for read < n {
		if r.head == r.tail {
			if !r.loadMore() {
				return
			}
		}

		if read+r.tail-r.head < n {
			read += r.tail - r.head
			r.head = r.tail
			continue
		}

		r.head += n - read
		read += n - read
	}
}

// SkipBool skips a Bool in the reader.
func (r *Reader) SkipBool() {
	_ = r.readByte()
}

// SkipInt skips an Int in the reader.
func (r *Reader) SkipInt() {
	var offset int8
	for r.Error == nil {
		if offset == maxIntBufSize {
			return
		}

		b := r.readByte()
		if b&0x80 == 0 {
			break
		}
		offset++
	}
}

// SkipLong skips a Long in the reader.
func (r *Reader) SkipLong() {
	var offset int8
	for r.Error == nil {
		if offset == maxLongBufSize {
			return
		}

		b := r.readByte()
		if b&0x80 == 0 {
			break
		}
		offset++
	}
}

// SkipFloat skips a Float in the reader.
func (r *Reader) SkipFloat() {
	r.SkipNBytes(4)
}

// SkipDouble skips a Double in the reader.
func (r *Reader) SkipDouble() {
	r.SkipNBytes(8)
}

// SkipString skips a String in the reader.
func (r *Reader) SkipString() {
	size := r.ReadLong()
	if size <= 0 {
		return
	}
	r.SkipNBytes(int(size))
}

// SkipBytes skips Bytes in the reader.
func (r *Reader) SkipBytes() {
	size := r.ReadLong()
	if size <= 0 {
		return
	}
	r.SkipNBytes(int(size))
}