Skip to content

Commit 3167d64

Browse files
authored
Merge pull request #1 from realityengines/make_reader_public_2
Make newDataFileReader public, using IoReader
2 parents 4441637 + bf7332f commit 3167d64

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

data_file.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ func NewDataFileReader(filename string, ignoreMe ...DatumReader) (*DataFileReade
9090
return nil, err
9191
}
9292

93-
reader, err := newDataFileReader(f)
93+
reader, err := NewDataFileReader_IoReader(f)
9494
if err != nil {
9595
// If there's any decoding issues, try not leaking a file handle.
9696
f.Close()
@@ -99,7 +99,7 @@ func NewDataFileReader(filename string, ignoreMe ...DatumReader) (*DataFileReade
9999

100100
}
101101

102-
func newDataFileReader(input io.Reader) (reader *DataFileReader, err error) {
102+
func NewDataFileReader_IoReader(input io.Reader) (reader *DataFileReader, err error) {
103103
dec := NewBinaryDecoderReader(input) // Since dec doesn't buffer, we can share it.
104104
reader = &DataFileReader{
105105
sharedCopyBuf: make([]byte, 4096),

data_file_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ func TestDataFileWriter(t *testing.T) {
4747
assert(t, len(encoded), 1145)
4848

4949
// now make sure we can decode again
50-
dfr, err := newDataFileReader(bytes.NewReader(encoded))
50+
dfr, err := NewDataFileReader_IoReader(bytes.NewReader(encoded))
5151
if err != nil {
5252
t.Fatal(err)
5353
}

0 commit comments

Comments
 (0)