Versions in this module Expand all Collapse all v0 v0.0.1 Oct 22, 2025 v0.0.0 Oct 22, 2025 Changes in this version + type ErrorType = constraint.ErrorType + type Task struct + Arg A + Erx E + Res R + type TaskBatch struct + Glide bool + Tasks Tasks[A, R, E] + func NewTaskBatch[A any, R any, E ErrorType](args []A) *TaskBatch[A, R, E] + func (t *TaskBatch[A, R, E]) EgoRun(ego *erxgroup.Group[E], run func(ctx context.Context, arg A) (R, E)) + func (t *TaskBatch[A, R, E]) GetRun(idx int, run func(ctx context.Context, arg A) (R, E)) func(ctx context.Context) E + func (t *TaskBatch[A, R, E]) SetGlide(glide bool) + func (t *TaskBatch[A, R, E]) SetWaCtx(waCtx func(err error) E) + type TaskOutput struct + Arg ARG + Erx E + Res RES + func NewOkTaskOutput[ARG any, RES any, E ErrorType](arg ARG, res RES) *TaskOutput[ARG, RES, E] + func NewWaTaskOutput[ARG any, RES any, E ErrorType](arg ARG, erx E) *TaskOutput[ARG, RES, E] + type TaskOutputList []*TaskOutput[ARG, RES, E] + func (rs TaskOutputList[ARG, RES, E]) OkCount() int + func (rs TaskOutputList[ARG, RES, E]) OkList() TaskOutputList[ARG, RES, E] + func (rs TaskOutputList[ARG, RES, E]) OkResults() []RES + func (rs TaskOutputList[ARG, RES, E]) WaCount() int + func (rs TaskOutputList[ARG, RES, E]) WaList() TaskOutputList[ARG, RES, E] + func (rs TaskOutputList[ARG, RES, E]) WaReasons() []E + type Tasks []*Task[A, R, E] + func (tasks Tasks[A, R, E]) Flatten(newWaFunc func(arg A, erx E) R) []R + func (tasks Tasks[A, R, E]) OkTasks() Tasks[A, R, E] + func (tasks Tasks[A, R, E]) WaTasks() Tasks[A, R, E]
Go to main page