asyncio

Nov 7, 2023

Changes in this version

+ func Delay(seconds float64, fn any, args ...any)

+ func ForEachPtrV(args S, f func(*E) V) []V

+ func ForEachV(args S, f func(E) V) []V

+ func ForFuncV(arg E, f ...func(E) V) []V

+ func MapR(m M, f func(K, V) R) []R

type Task

+ func (t *Task) Delay(seconds float64) *Task

Nov 3, 2023

Changes in this version

+ func ForFunc(arg E, f ...func(E))

Oct 28, 2023

Changes in this version

+ var ErrNoResult = errors.New("task has no rusult")

+ var ErrNoSecondResult = errors.New("task has no second rusult")

+ func Fill(tasks []*Task, s S, position ...int)

+ func ForEachPtr(args S, f func(*E))

+ func Loop(f func(loop EventLoop))

+ func Promise(fn any, args ...any) (p *promise)

+ func PromiseTask(task *Task) *promise

+ func Results(tasks []*Task, position ...int) []E

+ func RetryErrorTask(times int, delay float64, task *Task) bool

+ func RetryTask(times int, delay float64, task *Task) bool

+ func RunForever(tasks ...*Task)

+ func RunUntilComplete(tasks ...*Task)

+ func WaitGroup(delta int, f func(done func()))

type AbstractEventLoop

+ func (loop *AbstractEventLoop) Finish()

+ func (loop *AbstractEventLoop) Start()

+ func (loop *AbstractEventLoop) Stop()

+ type EventLoop interface

+ CreateTask func(fn any, args ...any) *Task

+ Run func(task *Task)

+ RunForever func(tasks ...*Task)

+ RunUntilComplete func(tasks ...*Task)

+ Start func()

+ Stop func()

+ type Status int

+ const Running

type Task

+ func CreateTask(fn any, args ...any) *Task

+ func (t *Task) AddDoneCallback(c func(*Task)) *Task

+ func (t *Task) Bool2() bool

+ func (t *Task) Check() bool

+ func (t *Task) Check2() bool

+ func (t *Task) Copy(args ...any) *Task

+ func (t *Task) Default(args ...any) *Task

+ func (t *Task) Done() bool

+ func (t *Task) Error2() error

+ func (t *Task) First() any

+ func (t *Task) Reflect(args reflect.Value) *Task

+ func (t *Task) Result() []any

+ func (t *Task) Second() any

Sep 14, 2023

Changes in this version

+ func ForEachP(args []T, f func(*T))

Sep 13, 2023

Changes in this version

+ func Do(f func(loop *AbstractEventLoop))

type AbstractEventLoop

+ func (loop *AbstractEventLoop) Callback(callback func([]any), f any, args ...any) *Handle

Sep 10, 2023

Changes in this version

+ const MIN

type Event

+ func (e Event) String() string

Sep 9, 2023

Changes in this version

+ func ForEach(args []T, f func(T))

type AbstractEventLoop

+ func (loop *AbstractEventLoop) Run(task *Task)

type H

+ func Wait(coros ...Coro) H

type Task

+ func (t *Task) Run()

Sep 6, 2023

Changes in this version

+ const ALL

+ func OnlyData(handle func(T)) func(*Event)

+ func WithData(handles ...func(*Event, T)) func(*Event)

type AsyncEvent

+ func (a AsyncEvent) OnAll(handles ...func(*Event)) func()

type Event

+ func (e *Event) New()

+ func (e *Event) Reset()

+ func (e *Event) Store(name string, value any)

Aug 26, 2023

Changes in this version

+ func Heartbeat(initdead, keepalive int, name string, f func())

+ func Stop(name string)

type Coro

+ func (c Coro) Task() *Task

Aug 25, 2023

Changes in this version

type AsyncEvent

+ func (a AsyncEvent) Heartbeat(initdead, keepalive int, f func(stop func()))

type Coro

+ func (c Coro) Callback(f func([]any)) *Task

type Task

+ func (t *Task) Bool() bool

+ func (t *Task) Error() error

Aug 20, 2023

Changes in this version

+ type AsyncEvent map[string]model

+ func (a AsyncEvent) All(handles ...func(*Event)) (delete func())

+ func (a AsyncEvent) Dispatch(cmd string, data any)

+ func (a AsyncEvent) On(name, cmd string, handles ...func(*Event)) func()

+ func (a AsyncEvent) OnCommand(cmd string, handles ...func(*Event)) (delete func())

+ func (a AsyncEvent) OnRegexp(pattern string, handles ...func(*Event)) (delete func())

+ func (a AsyncEvent) Register(name string, choose func(cmd, key string) bool)

+ func (a AsyncEvent) Registered(name string) bool

+ type Event struct

+ func (e *Event) Abort()

+ func (e *Event) Cmd() string

+ func (e *Event) Data() any

+ func (e *Event) Get(name string) any

+ func (e *Event) Set(name string, value any)

Aug 18, 2023

Changes in this version

+ func Retry(times, delay int, f func() bool)

+ func RetryError(times, delay int, f func() error)

+ func RetryErrorWith(times, delay int, coro Coro)

+ func RetryWith(times, delay int, coro Coro)

+ func SetEventLoop(loop *AbstractEventLoop)

+ func To(H H, ts ...S) []T

+ type AbstractEventLoop struct

+ func GetEventLoop() *AbstractEventLoop

+ func NewEventLoop() *AbstractEventLoop

+ func (loop *AbstractEventLoop) Coro(f any, args ...any) *Handle

+ func (loop *AbstractEventLoop) CreateTask(coro Coro) *Handle

+ func (loop *AbstractEventLoop) RunForever()

+ func (loop *AbstractEventLoop) RunUntilComplete()

+ type Args []any

+ func SingleArg(args ...T) []Args

+ type Coro struct

+ Args Args

+ Func any

+ func C(f any, args ...any) Coro

+ func NoArgsFunc(fs ...any) []Coro

+ func (c Coro) ToTask() *Task

+ type H []*Handle

+ func Await(coros ...Coro) H

+ func List(f any, args []Args) H

+ func Map(f any, m M) H

+ func Slice(f any, args []Args) H

+ func (H H) Len() (sum int)

+ type Handle struct

+ func (h *Handle) Done() bool

+ func (h *Handle) Len() int

+ func (h *Handle) Result() []any

+ type Task struct

+ Args []reflect.Value

+ Func reflect.Value