bytebatch

Jul 12, 2016

Changes in this version

+ type ByteBatch struct

+ func NewByteBatch(cap int) *ByteBatch

+ func (bb *ByteBatch) Add(b []byte)

+ func (bb *ByteBatch) Reset()

+ func (bb *ByteBatch) Size() int

+ func (bb *ByteBatch) Slice() [][]byte

+ type ByteFunc func([]byte) ([]byte, error)

+ type LineProcessor struct

+ BatchSize int

+ LineSeparator byte

+ NumWorkers int

+ func NewLineProcessor(r io.Reader, w io.Writer, f ByteFunc) *LineProcessor

+ func (p LineProcessor) Run() error