taskgroup

May 19, 2026

Changes in this version

type Single

+ func (s *Single[T]) Done() <-chan struct{}

Nov 14, 2024

Changes in this version

+ type StartFunc func(Task)

+ func (s StartFunc) Go(task Task)

+ func (s StartFunc) Run(f func())

Oct 6, 2024

Changes in this version

+ type Gatherer struct

+ func Gather[T any](run func(Task), gather func(T)) *Gatherer[T]

+ func (g *Gatherer[T]) Call(f func() (T, error))

+ func (g *Gatherer[T]) Report(f func(report func(T)) error)

+ func (g *Gatherer[T]) Run(f func() T)

type Group

+ func (g *Group) OnError(ef any) *Group

+ type Leaver func()

+ func (f Leaver) Leave()

+ type Throttle struct

+ func NewThrottle(n int) Throttle

+ func (t Throttle) Enter() Leaver

+ func (t Throttle) Limit(g *Group) func(Task)

Sep 7, 2024

Changes in this version

type Collector

+ func Collect[T any](value func(T)) *Collector[T]

+ func (c *Collector[T]) Call(f func() (T, error)) Task

+ func (c *Collector[T]) Run(f func() T) Task

Sep 6, 2024

Changes in this version

type Group

+ func (g *Group) Run(task func()) *Group

type Single

+ func Run(task func()) *Single[error]

Mar 19, 2024

Changes in this version

type Collector

+ func (c *Collector[T]) Report(f func(report func(T)) error) Task

Jan 13, 2024

Changes in this version

type Collector

+ func (c *Collector[T]) Stream(f func(chan<- T) error) Task

Jan 13, 2024

Changes in this version

+ type Collector struct

+ func NewCollector[T any](value func(T)) *Collector[T]

+ func (c *Collector[T]) NoError(f func() T) Task

+ func (c *Collector[T]) Task(f func() (T, error)) Task

+ func (c *Collector[T]) Wait()

Sep 5, 2023

Changes in this version

type Result

+ func (r Result[T]) Get() (T, error)

May 1, 2023

Changes in this version

+ type Result struct

+ Err error

+ Value T

type Single

+ func Call(task func() (T, error)) *Single[Result[T]]

Mar 18, 2023

Changes in this version

type Task

+ func NoError(f func()) Task

Jan 18, 2023

Changes in this version

type Single

+ func Go(task Task) *Single

+ func (s *Single) Wait() error

Dec 31, 2022

Changes in this version

+ type Solo struct

+ func Single(task Task) *Solo

+ func (s *Solo) Wait() error

Jun 10, 2019

Changes in this version

+ type ErrorFunc func(error) error

+ func Listen(f func(error)) ErrorFunc

+ func Trigger(f func()) ErrorFunc

+ type Group struct

+ func New(ef ErrorFunc) *Group

+ func (g *Group) Go(task Task) *Group

+ func (g *Group) Limit(n int) (*Group, func(Task) *Group)

+ func (g *Group) Wait() error

+ type Task func() error