batch

Documentation

Index

• type BufferedChunkReader
  • func New(cr ChunkReader) *BufferedChunkReader
  • func (r *BufferedChunkReader) Read(b []byte) (int, error)
• type ChunkReader

Types

type BufferedChunkReader

type BufferedChunkReader struct {
	// contains filtered or unexported fields
}

func New

func New(cr ChunkReader) *BufferedChunkReader

func (*BufferedChunkReader) Read

func (r *BufferedChunkReader) Read(b []byte) (int, error)

type ChunkReader

type ChunkReader interface {
	GetChunk() ([]byte, error)
}