background

Documentation

Overview

Package background implements functions to execute tasks in a separate goroutine.

Index

• Variables
• type Worker
  • func New[T any](ctx context.Context, n int, fn func(context.Context, T)) (*Worker[T], func())
  • func (w *Worker[T]) Send(vs ...T) error

Variables

var ErrTerminated = errors.New("worker: terminated")

Types

type Worker

type Worker[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](ctx context.Context, n int, fn func(context.Context, T)) (*Worker[T], func())

New returns a new background manager.

func (*Worker[T]) Send

func (w *Worker[T]) Send(vs ...T) error

Send sends a new message to the channel.