work_process

Documentation

Index

• type WorkProcess
  • func New[T any](env environment, name string, consumer func(inp T)) *WorkProcess[T]
  • func (wp *WorkProcess[T]) Start()

Types

type WorkProcess

type WorkProcess[T any] struct {
	*queue.Queue[T]
	Name string
	// contains filtered or unexported fields
}

func New

func New[T any](env environment, name string, consumer func(inp T)) *WorkProcess[T]

func (*WorkProcess[T]) Start

func (wp *WorkProcess[T]) Start()