Function counter

flow/loop_test.go:10–16

counter body: increments an integer carried in State.Data.

()

// counter body: increments an integer carried in State.Data.
func counter() StepFunc {
	return func(ctx context.Context, in State) (State, error) {
		n, _ := strconv.Atoi(in.String())
		in.Data = []byte(strconv.Itoa(n + 1))
		return in, nil
	}
}

func TestLoopUntil(t *testing.T) {
	step := Loop(counter(),