Rename valueReaderByteSrc to byteSrc

Author: prestonvasquez

bson/buffered_byte_src.go

@@ -19,7 +19,7 @@ type bufferedByteSrc struct {
 	offset int64  // Current read index into buf
 }
 
-var _ valueReaderByteSrc = (*bufferedByteSrc)(nil)
+var _ byteSrc = (*bufferedByteSrc)(nil)
 
 // Read reads up to len(p) bytes from the in-memory buffer, advancing the offset
 // by the number of bytes read.

bson/streaming_byte_src.go

@@ -22,7 +22,7 @@ type streamingByteSrc struct {
 	offset int64 // offset is the current read position in the buffer
 }
 
-var _ valueReaderByteSrc = (*streamingByteSrc)(nil)
+var _ byteSrc = (*streamingByteSrc)(nil)
 
 // Read reads up to len(p) bytes from the underlying bufio.Reader, advancing
 // the offset by the number of bytes read.

bson/value_reader.go

@@ -16,7 +16,7 @@ import (
 	"sync"
 )
 
-type valueReaderByteSrc interface {
+type byteSrc interface {
 	io.ByteReader
 
 	readExact(p []byte) (int, error)
@@ -72,7 +72,7 @@ var vrPool = sync.Pool{
 
 // valueReader is for reading BSON values.
 type valueReader struct {
-	src    valueReaderByteSrc
+	src    byteSrc
 	offset int64
 
 	stack []vrState
@@ -278,7 +278,7 @@ func peekNextValueSize(vr *valueReader) (int32, error) {
 
 // readBytes tries to grab the next n bytes zero-allocation using peek+discard.
 // If peek fails (e.g. bufio buffer full), it falls back to io.ReadFull.
-func readBytes(src valueReaderByteSrc, n int) ([]byte, error) {
+func readBytes(src byteSrc, n int) ([]byte, error) {
 	if src.streamable() {
 		data := make([]byte, n)
 		if _, err := src.readExact(data); err != nil {