Source File
	msg_reader.go

Belonging Package
	github.com/libp2p/go-libp2p/p2p/protocol/autonatv2

package autonatv2

import (
	"io"

	"github.com/multiformats/go-varint"
)

// msgReader reads a varint prefixed message from R without any buffering
type msgReader struct {
	R   io.Reader
	Buf []byte
}

func (m *msgReader) ReadByte() (byte, error) {
	buf := m.Buf[:1]
	_, err := m.R.Read(buf)
	return buf[0], err
}

func (m *msgReader) ReadMsg() ([]byte, error) {
	sz, err := varint.ReadUvarint(m)
	if err != nil {
		return nil, err
	}
	if sz > uint64(len(m.Buf)) {
		return nil, io.ErrShortBuffer
	}
	n := 0
	for n < int(sz) {
		nr, err := m.R.Read(m.Buf[n:sz])
		if err != nil {
			return nil, err
		}
		n += nr
	}
	return m.Buf[:sz], nil
}

The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds.