xprocess

Jan 26, 2021

Changes in this version

+ type Value = xprocess_abc.Value

Jan 25, 2021

Changes in this version

+ func AwaitFn(fn interface{}, args ...interface{}) xprocess_abc.FutureValue

+ func CostWith(fn func()) time.Duration

+ func Count(n int) <-chan int

+ func MemStatsPrint()

+ func Test(fn interface{}) *xprocess_test.Test

+ func Tick(args ...interface{}) <-chan time.Time

+ func Try(fn func()) error

Jan 7, 2021

Changes in this version

+ func NewEvent() *xprocess_event.Event

type WaitGroup

+ func NewWaitGroup(check uint8, c ...uint16) WaitGroup

Jan 1, 2021

Changes in this version

+ func Map(data interface{}, fn interface{}) interface

+ type Future interface

+ Await func(val FutureValue, fn interface{})

+ Cancel func()

+ Yield func(data interface{}, fn ...interface{})

+ type FutureValue interface

+ Err func() error

+ Get func() []reflect.Value

+ String func() string

+ Value func(fn interface{})

+ func Async(fn interface{}, args ...interface{}) FutureValue

+ func Await(val FutureValue, fn interface{}) FutureValue

+ type IPromise interface

+ Cancelled func() bool

+ Value func(fn interface{})

+ Wait func() error

+ func Promise(fn func(g Future)) IPromise

+ type WaitGroup struct

+ Check int8

+ Concurrent int16

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

+ func (t *WaitGroup) Count() int16

+ func (t *WaitGroup) Dec()

+ func (t *WaitGroup) Inc()

Dec 26, 2020

Changes in this version

+ type Stream interface

+ Await func(func(data interface{}))

+ Chan func() chan interface{}

+ Stream func(fn func(y Yield), nums ...int) Stream

+ func NewStream(fn func(y Yield), nums ...int) Stream

+ type Yield interface

+ Go func(fn func())

+ Yield func(data interface{})

Dec 12, 2020

Changes in this version

+ var Break = xerror.New("break")

Dec 12, 2020

Changes in this version

+ func GoDelay(dur time.Duration, fn func(ctx context.Context)) context.CancelFunc

Dec 7, 2020

Changes in this version

+ type GroupOption func(*group)

+ func WithConcurrency(c uint32) GroupOption

Dec 5, 2020

Changes in this version

+ var ErrTimeout = xerror.New("timeout")

Oct 28, 2020

Changes in this version

+ func Timeout(dur time.Duration, fn func(ctx context.Context) error) error

+ type Group = group

Oct 12, 2020

Changes in this version

+ func Go(fn func(ctx context.Context) error) func() error

+ func GoLoop(fn func(ctx context.Context) error) func() error

+ func NewGroup(ctx context.Context) *group

+ func Stack() string