io

Jul 26, 2024

Changes in this version

+ const LLGoPackage

+ func Await2[OutT1, OutT2 any](ac1 AsyncCall[OutT1], ac2 AsyncCall[OutT2], timeout ...time.Duration) (ret1 OutT1, ret2 OutT2, err error)

+ func Await3[OutT1, OutT2, OutT3 any](ac1 AsyncCall[OutT1], ac2 AsyncCall[OutT2], ac3 AsyncCall[OutT3], ...) (ret1 OutT1, ret2 OutT2, ret3 OutT3, err error)

+ func Await[OutT any](call AsyncCall[OutT], timeout ...time.Duration) (ret OutT, err error)

+ func Run(ac AsyncCall[Void])

+ type AsyncCall interface

+ Await func(timeout ...time.Duration) (ret OutT, err error)

+ Chan func() <-chan OutT

+ EnsureDone func()

+ func Timeout(time.Duration) (ret AsyncCall[Void])

+ type Await2Result struct

+ Err error

+ V1 T1

+ V2 T2

+ type Await3Result struct

+ Err error

+ V1 T1

+ V2 T2

+ V3 T3

+ type Promise func(OutT, error)

+ func (p Promise[OutT]) Await(timeout ...time.Duration) (ret OutT, err error)

+ func (p Promise[OutT]) Chan() <-chan OutT

+ func (p Promise[OutT]) EnsureDone()

+ type PromiseImpl struct

+ Err error

+ Func func(resolve func(TOut, error))

+ Next int

+ Prev int

+ Value TOut

+ func All[OutT any](acs []AsyncCall[OutT]) (ret *PromiseImpl[[]OutT])

+ func Await2Compiled[OutT1, OutT2 any](ac1 AsyncCall[OutT1], ac2 AsyncCall[OutT2], timeout ...time.Duration) (ret *PromiseImpl[Await2Result[OutT1, OutT2]])

+ func Await3Compiled[OutT1, OutT2, OutT3 any](ac1 AsyncCall[OutT1], ac2 AsyncCall[OutT2], ac3 AsyncCall[OutT3], ...) (ret *PromiseImpl[Await3Result[OutT1, OutT2, OutT3]])

+ func Race[OutT any](acs ...AsyncCall[OutT]) (ret *PromiseImpl[OutT])

+ func TimeoutCompiled(d time.Duration) *PromiseImpl[Void]

+ func (p *PromiseImpl[TOut]) Await(timeout ...time.Duration) (ret TOut, err error)

+ func (p *PromiseImpl[TOut]) Chan() <-chan TOut

+ func (p *PromiseImpl[TOut]) EnsureDone()

+ func (p *PromiseImpl[TOut]) Resume()

+ type Void = [0]byte