asyncprocessor

Documentation

Overview

Package asyncprocessor contains an asynchronous processor.

Index

• type Processor
  • func (w *Processor) Close()
  • func (w *Processor) Initialize()
  • func (w *Processor) Push(cb func() error) bool
  • func (w *Processor) Start()

Types

type Processor

type Processor struct {
	BufferSize int
	OnError    func(context.Context, error)
	// contains filtered or unexported fields
}

Processor is an asynchronous queue processor that allows to detach the routine that is reading a stream from the routine that is writing a stream.

func (*Processor) Close

func (w *Processor) Close()

Close closes the processor.

func (*Processor) Initialize

func (w *Processor) Initialize()

Initialize initializes the processor.

func (*Processor) Push

func (w *Processor) Push(cb func() error) bool

Push pushes data to the queue.

func (*Processor) Start

func (w *Processor) Start()

Start starts the processor.