Merge pull request #25 from ipld/fix/no-private-types

don't use private types in public functions

car.go

@@ -105,12 +105,12 @@ func (cw *carWriter) writeNode(ctx context.Context, nd format.Node) error {
  return util.LdWrite(cw.w, nd.Cid().Bytes(), nd.RawData())
 }
 
-type carReader struct {
+type CarReader struct {
  br *bufio.Reader
  Header *CarHeader
 }
 
-func NewCarReader(r io.Reader) (*carReader, error) {
+func NewCarReader(r io.Reader) (*CarReader, error) {
  br := bufio.NewReader(r)
  ch, err := ReadHeader(br)
  if err != nil {
@@ -125,13 +125,13 @@ func NewCarReader(r io.Reader) (*carReader, error) {
  return nil, fmt.Errorf("invalid car version: %d", ch.Version)
  }
 
- return &carReader{
+ return &CarReader{
  br: br,
  Header: ch,
  }, nil
 }
 
-func (cr *carReader) Next() (blocks.Block, error) {
+func (cr *CarReader) Next() (blocks.Block, error) {
  c, data, err := util.ReadNode(cr.br)
  if err != nil {
  return nil, err
@@ -166,7 +166,7 @@ func LoadCar(s Store, r io.Reader) (*CarHeader, error) {
  return loadCarSlow(s, cr)
 }
 
-func loadCarFast(s batchStore, cr *carReader) (*CarHeader, error) {
+func loadCarFast(s batchStore, cr *CarReader) (*CarHeader, error) {
  var buf []blocks.Block
  for {
  blk, err := cr.Next()
@@ -192,17 +192,9 @@ func loadCarFast(s batchStore, cr *carReader) (*CarHeader, error) {
  buf = buf[:0]
  }
  }
-
- if len(buf) > 0 {
- if err := s.PutMany(buf); err != nil {
- return nil, err
- }
- }
-
- return cr.Header, nil
 }
 
-func loadCarSlow(s Store, cr *carReader) (*CarHeader, error) {
+func loadCarSlow(s Store, cr *CarReader) (*CarHeader, error) {
 
  for {
  blk, err := cr.Next()