Function NewEndlessReader

msgp/circular.go:19–28

NewEndlessReader returns a new endless reader. Buffer b cannot be empty

(b []byte, tb timer)

// NewEndlessReader returns a new endless reader.
// Buffer b cannot be empty
func NewEndlessReader(b []byte, tb timer) *EndlessReader {
	if len(b) == 0 {
		panic("EndlessReader cannot be of zero length")
	}
	// Double until we reach 4K.
	for len(b) < 4<<10 {
		b = append(b, b...)
	}
	return &EndlessReader{tb: tb, data: b, offset: 0}
}

// Read implements io.Reader. In practice, it
// always returns (len(p), nil), although it