Versions in this module Expand all Collapse all v0 v0.2.0 Aug 31, 2024 Changes in this version + type Packer struct + func NewPacker(in io.Reader, out, err io.Writer, processor Processor, opts ...PackerOpt) *Packer + func NewPackerStd(processor Processor, opts ...PackerOpt) *Packer + func NewPackerStdOut(in io.Reader, processor Processor, opts ...PackerOpt) *Packer + func (p *Packer) Execute() + type PackerOpt func(*packerOpts) + func WithErrWriteHandler(f func(error)) PackerOpt + type ProcOpt func(*procOpts) + func Parallel(p int) ProcOpt + type Processor interface + ErrChan func() chan error + InChan func() chan []byte + OutChan func() chan []byte + func NewProcessor[T data](transform func(T) ([]T, error), opts ...ProcOpt) Processor
Go to main page