Method Work

client_test.go:104–139

(ctx context.Context, job *Job[resumableClientTestArgs])

}

func (w *resumableClientTestWorker) Work(ctx context.Context, job *Job[resumableClientTestArgs]) error {
	appendCall := func(call string) {
		w.callsMu.Lock()
		defer w.callsMu.Unlock()

		w.calls = append(w.calls, call)
	}

	ResumableStep(ctx, "step1", nil, func(ctx context.Context) error {
		appendCall("step1")
		return nil
	})

	ResumableStepCursor(ctx, "step2", nil, func(ctx context.Context, cursor int) error {
		appendCall("step2:" + strconv.Itoa(cursor))

		for itemID := cursor + 1; itemID <= 2; itemID++ {
			appendCall("item:" + strconv.Itoa(itemID))
			if err := ResumableSetCursor(ctx, itemID); err != nil {
				return err
			}
			if !w.failedOnce.Swap(true) {
				return errors.New("retry me")
			}
		}

		return nil
	})

	ResumableStep(ctx, "step3", nil, func(ctx context.Context) error {
		appendCall("step3")
		return nil
	})

	return nil
}

func makeAwaitWorker[T JobArgs](startedCh chan<- int64, doneCh chan struct{}) Worker[T] {
	return WorkFunc(func(ctx context.Context, job *Job[T]) error {