Function TestLoopUntil

flow/loop_test.go:18–33

(t *testing.T)

}

func TestLoopUntil(t *testing.T) {
	step := Loop(counter(),
		Until(func(ctx context.Context, s State, iter int) (bool, error) {
			n, _ := strconv.Atoi(s.String())
			return n >= 3, nil
		}),
		LoopMax(100),
	)
	out, err := step(context.Background(), State{Data: []byte("0")})
	if err != nil {
		t.Fatal(err)
	}
	if out.String() != "3" {
		t.Fatalf("expected 3, got %q", out.String())
	}
}

func TestLoopMaxCapStops(t *testing.T) {
	runs := 0