Versions in this module Expand all Collapse all v0 v0.1.1 Mar 18, 2024 Changes in this version + var New = NewProcessor + type Processor struct + BatchSize int + F func([]byte) ([]byte, error) + NumWorkers int + R io.Reader + SplitFunc bufio.SplitFunc + Verbose bool + W io.Writer + func NewProcessor(r io.Reader, w io.Writer, f func([]byte) ([]byte, error)) *Processor + func (p *Processor) Run() error + func (p *Processor) Split(f bufio.SplitFunc)
Go to main page