task

Documentation

Index

• type Executor
  • func NewTaskExecutor[T any]() *Executor[T]
  • func NewTaskExecutorWithBuffer[T any](bufferSize int) *Executor[T]
  • func (t *Executor[T]) AddTask(c context.Context, task func(context.Context) (T, error))
  • func (t *Executor[T]) Results() Results[T]
  • func (t *Executor[T]) Wait()
• type Result
• type Results
  • func (r Results[T]) AnyError() error

Types

type Executor

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

func NewTaskExecutor

func NewTaskExecutor[T any]() *Executor[T]

func NewTaskExecutorWithBuffer

func NewTaskExecutorWithBuffer[T any](bufferSize int) *Executor[T]

func (*Executor[T]) AddTask

func (t *Executor[T]) AddTask(c context.Context, task func(context.Context) (T, error))

func (*Executor[T]) Results

func (t *Executor[T]) Results() Results[T]

func (*Executor[T]) Wait

func (t *Executor[T]) Wait()

type Result

type Result[T any] struct {
	Value T
	Error error
}

type Results

type Results[T any] struct {
	Values []Result[T]
}

func (Results[T]) AnyError

func (r Results[T]) AnyError() error