async

Jan 10, 2026

Changes in this version

type Coroutine

+ func (co *Coroutine) Panic(v any) Result

+ func (co *Coroutine) RecoverFunc(f func(v any) bool) (v any)

type PendingResult

+ func (pr PendingResult) Panic(v any) Result

type Task

+ func Panic(v any) Task

Dec 27, 2025

Changes in this version

type Coroutine

+ func (co *Coroutine) NonCancelable() bool

type Semaphore

+ func (s *Semaphore) TryAcquire(n Weight) bool

type Task

+ func NonCancelable(t Task) Task

Nov 29, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Canceled() bool

Nov 15, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Panicking() bool

+ func (co *Coroutine) Recover() (v any)

+ func (co *Coroutine) Recover2() (v any, stacktrace []byte)

+ func (co *Coroutine) Throw(v any) Result

type PendingResult

+ func (pr PendingResult) Throw(v any) Result

type Task

+ func Throw(v any) Task

Sep 27, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Ended() bool

+ func (co *Coroutine) Escape()

+ func (co *Coroutine) Unescape()

type PendingResult

+ func (pr PendingResult) Exit() Result

Aug 30, 2025

retracted

Changes in this version

+ type PendingResult struct

+ func (pr PendingResult) Break() Result

+ func (pr PendingResult) Continue() Result

+ func (pr PendingResult) End() Result

+ func (pr PendingResult) Reiterate() Result

+ func (pr PendingResult) Return() Result

+ func (pr PendingResult) Then(t Task) Result

+ func (pr PendingResult) Until(f func() bool) PendingResult

type State

+ func (s *State[T]) Await(f func(v T) bool) Task

type Task

+ func ConcatSeq(seq iter.Seq[Task]) Task

+ func MergeSeq(concurrency int, seq iter.Seq[Task]) Task

+ func Spawn(t Task) Task

Aug 2, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Parent() *Coroutine

+ func (co *Coroutine) Resume()

Jul 26, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Resumed() bool

type Task

+ func Enclose(t Task) Task

Jul 6, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Transition(t Task) Result

Jun 1, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Weight() Weight

type Executor

+ func (e *Executor) UsePool(p *sync.Pool)

May 11, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) SpawnWeighted(w Weight, t Task)

type Executor

+ func (e *Executor) SpawnWeighted(w Weight, t Task)

+ type Weight int

Apr 27, 2025

retracted

Changes in this version

+ type Cleanup interface

+ Cleanup func()

+ type CleanupFunc func()

+ func (f CleanupFunc) Cleanup()

type Coroutine

+ func (co *Coroutine) CleanupFunc(f func())

type Task

+ func Join(s ...Task) Task

+ func Select(s ...Task) Task

Apr 6, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) AwaitSeq(seq iter.Seq[Event]) Result

+ func (co *Coroutine) Exiting() bool

+ func (co *Coroutine) WatchSeq(seq iter.Seq[Event])

type Task

+ func AwaitSeq(seq iter.Seq[Event]) Task

+ func FromSeq(seq iter.Seq[Task]) Task

Mar 23, 2025

retracted

Changes in this version

type Coroutine

+ func (co *Coroutine) Break() Result

+ func (co *Coroutine) BreakLabel(l Label) Result

+ func (co *Coroutine) Cleanup(f func())

+ func (co *Coroutine) Continue() Result

+ func (co *Coroutine) ContinueLabel(l Label) Result

+ func (co *Coroutine) Exit() Result

+ func (co *Coroutine) Return() Result

+ func (co *Coroutine) Transit(t Task) Result

+ type Label string

+ const NoLabel

type State

+ func (s *State[T]) Update(f func(v T) T)

type Task

+ func Await(ev ...Event) Task

+ func Block(s ...Task) Task

+ func Break() Task

+ func BreakLabel(l Label) Task

+ func Continue() Task

+ func ContinueLabel(l Label) Task

+ func Defer(t Task) Task

+ func End() Task

+ func Exit() Task

+ func Func(t Task) Task

+ func Loop(t Task) Task

+ func LoopLabel(l Label, t Task) Task

+ func LoopLabelN(l Label, n int, t Task) Task

+ func LoopN(n int, t Task) Task

+ func Return() Task

Dec 30, 2024

retracted

Changes in this version

+ type Coroutine struct

+ func (co *Coroutine) Await(s ...Event) Result

+ func (co *Coroutine) Defer(f func())

+ func (co *Coroutine) End() Result

+ func (co *Coroutine) Executor() *Executor

+ func (co *Coroutine) Path() string

+ func (co *Coroutine) Spawn(p string, t Task)

+ func (co *Coroutine) Switch(t Task) Result

+ func (co *Coroutine) Watch(s ...Event)

+ func (co *Coroutine) Yield(t Task) Result

+ type Semaphore struct

+ func NewSemaphore(n int64) *Semaphore

+ func (s *Semaphore) Acquire(n int64) Task

+ func (s *Semaphore) Release(n int64)

type Task

+ func NoOperation() Task

+ func (t Task) Then(next Task) Task

+ type WaitGroup struct

+ func (wg *WaitGroup) Add(delta int)

+ func (wg *WaitGroup) Await() Task

+ func (wg *WaitGroup) Counter() int

+ func (wg *WaitGroup) Done()

Dec 26, 2024

retracted

Changes in this version

+ type Event interface

+ type Executor struct

+ func (e *Executor) Autorun(f func())

+ func (e *Executor) Run()

+ func (e *Executor) Spawn(p string, op Operation)

+ type Memo struct

+ func NewMemo[T any](e *Executor, p string, f func(t *Task, s *State[T])) *Memo[T]

+ func NewStrictMemo[T any](e *Executor, p string, f func(t *Task, s *State[T])) *Memo[T]

+ func (m *Memo[T]) Get() T

+ type Operation func(t *Task) Result

+ func Chain(s ...Operation) Operation

+ func Do(f func()) Operation

+ func Never() Operation

+ func Nop() Operation

+ func (op Operation) Then(next Operation) Operation

+ type Result struct

+ type Signal struct

+ func (s *Signal) Notify()

+ type State struct

+ func NewState[T any](v T) *State[T]

+ func (s *State[T]) Get() T

+ func (s *State[T]) Set(v T)

+ type Task struct

+ func (t *Task) Await(s ...Event) Result

+ func (t *Task) Defer(f func())

+ func (t *Task) End() Result

+ func (t *Task) Executor() *Executor

+ func (t *Task) Path() string

+ func (t *Task) Spawn(p string, op Operation)

+ func (t *Task) Switch(op Operation) Result

+ func (t *Task) Watch(s ...Event)

+ func (t *Task) Yield(op Operation) Result