asynctask

Jun 27, 2023

Changes in this version

+ func WaitAny(ctx context.Context, options *WaitAnyOptions, tasks ...Waitable) error

+ type WaitAnyOptions struct

+ FailOnAnyError bool

Oct 27, 2022

Changes in this version

+ func ActionToFunc(action func(context.Context) error) func(context.Context) (*interface{}, error)

+ func AfterBothActionToFunc(action func(context.Context, *T, *S) error) func(context.Context, *T, *S) (*interface{}, error)

+ func ContinueActionToFunc(action func(context.Context, *T) error) func(context.Context, *T) (*interface{}, error)

Jul 5, 2022

Changes in this version

+ type AfterAll3Func func(context.Context, *T, *S, *R) (*Q, error)

+ type AfterAll4Func func(context.Context, *T, *S, *R, *Q) (*P, error)

+ type AfterAll5Func func(context.Context, *T, *S, *R, *Q, *P) (*O, error)

type Task

+ func AfterAll3(ctx context.Context, tskT *Task[T], tskS *Task[S], tskR *Task[R], ...) *Task[Q]

+ func AfterAll4(ctx context.Context, tskT *Task[T], tskS *Task[S], tskR *Task[R], ...) *Task[P]

+ func AfterAll5(ctx context.Context, tskT *Task[T], tskS *Task[S], tskR *Task[R], ...) *Task[O]

Jun 26, 2022

Changes in this version

+ type AfterBothFunc func(context.Context, *T, *S) (*R, error)

type Task

+ func AfterBoth(ctx context.Context, tskT *Task[T], tskS *Task[S], next AfterBothFunc[T, S, R]) *Task[R]

May 31, 2022

Changes in this version

+ type Task struct

+ func ContinueWith(ctx context.Context, tsk *Task[T], next ContinueFunc[T, S]) *Task[S]

+ func (t *Task[T]) Cancel()

+ func (t *Task[T]) Result(ctx context.Context) (*T, error)

+ func (t *Task[T]) State() State

+ func (t *Task[T]) Wait(ctx context.Context) error

+ func (t *Task[T]) WaitWithTimeout(ctx context.Context, timeout time.Duration) (*T, error)

+ type Waitable interface

+ Wait func(context.Context) error

Oct 6, 2020

Changes in this version

+ type ContinueFunc func(context.Context, interface{}) (interface{}, error)

type TaskStatus

+ func (tsk *TaskStatus) ContinueWith(ctx context.Context, next ContinueFunc) *TaskStatus

May 20, 2020

Changes in this version

+ func WaitAll(ctx context.Context, options *WaitAllOptions, tasks ...*TaskStatus) error

+ type WaitAllOptions struct

+ FailFast bool

Apr 13, 2020

Changes in this version

+ var ErrCanceled = errors.New("canceled")

type State

+ func (s State) IsTerminalState() bool

type TaskStatus

+ func NewCompletedTask() *TaskStatus

Mar 16, 2020

Changes in this version

+ var ErrPanic = errors.New("panic")

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

type TaskStatus

+ func (t *TaskStatus) WaitWithTimeout(timeout time.Duration) (interface{}, error)

Mar 6, 2020

Changes in this version

+ type AsyncFunc func(context.Context) (interface{}, error)

+ type State string

+ const StateCanceled

+ const StateCompleted

+ const StateFailed

+ const StateRunning

+ type TaskStatus struct

+ func Start(ctx context.Context, task AsyncFunc) *TaskStatus

+ func (t *TaskStatus) Cancel()

+ func (t *TaskStatus) State() State

+ func (t *TaskStatus) Wait() (interface{}, error)