pool

Documentation

Index

• type Processing
  • func New[E any](pool processing.Processing) *Processing[E]
  • func (p *Processing[E]) Execute(elem E, runner Runner[E])
  • func (p *Processing[E]) Wait()
• type Runner

Types

type Processing

type Processing[E any] struct {
	// contains filtered or unexported fields
}

func New

func New[E any](pool processing.Processing) *Processing[E]

func (*Processing[E]) Execute

func (p *Processing[E]) Execute(elem E, runner Runner[E])

func (*Processing[E]) Wait

func (p *Processing[E]) Wait()

type Runner

type Runner[E any] func(ctx context.Context, pool *Processing[E], elem E)