Versions in this module Expand all Collapse all v1 v1.1.2 Feb 2, 2026 Changes in this version + type Processor struct + BufferSize int + OnError func(context.Context, error) + func (w *Processor) Close() + func (w *Processor) Initialize() + func (w *Processor) Push(cb func() error) bool + func (w *Processor) Start()
Go to main page