Package io.axoniq.framework.workflow.runtime.test.fixture

Class Then.Phase

java.lang.Object

io.axoniq.framework.workflow.runtime.test.fixture.Phase<Then.Phase>

io.axoniq.framework.workflow.runtime.test.fixture.Then<Then.Phase,GivenWhen.Phase>

io.axoniq.framework.workflow.runtime.test.fixture.Then.Phase

Enclosing class:

Then<SELF extends Then<SELF,ACTION>,ACTION extends GivenWhen<ACTION,SELF>>

public static final class Then.Phase
extends Then<Then.Phase,GivenWhen.Phase>

Default implementation of the Then.

Nested Class Summary

Nested classes/interfaces inherited from class io.axoniq.framework.workflow.runtime.test.fixture.Then

Then.Phase

Field Summary

Fields

Modifier and Type	Field	Description
protected WorkflowTestFixture<?,?>	fixture
protected WorkflowTestDriver	testDriver

Constructor Summary

Constructors

Constructor	Description
Phase()

Method Summary

Modifier and Type	Method	Description
Then.Phase	executionExists()	Waits until any active workflow execution exists.
Then.Phase	executionExists(Predicate<WorkflowExecution> predicate)	Waits until an active workflow execution matching the predicate exists.
Then.Phase	historyExists(WorkflowStatus workflowStatus)	Waits until at least one workflow history exists and has the given status.
Then.Phase	historyExists(String workflowId)	Waits until a workflow history exists for the given workflow id.
Then.Phase	historyExists(Predicate<WorkflowHistory> predicate)	Waits until a workflow history matching the predicate exists.
protected void	initialize(WorkflowTestFixture<?,?> fixture, WorkflowTestDriver testDriver)	Initializes this phase with the owning fixture and the shared test driver.
Then.Phase	noExecution()	Asserts that no active workflow execution is present.
Then.Phase	noHistory()	Asserts that no workflow history is recorded.
void	stop()	Shuts down the test driver and all services.

Methods inherited from class io.axoniq.framework.workflow.runtime.test.fixture.Then

and, hasSteps, hasStepsInAnyOrder, noStep, payloadContains, payloadEquals, payloadMatches, payloadSatisfies, step, stepsPassed, waitingIn, workflowFinished, workflowNotFinished, workflowStateSatisfies

Methods inherited from class io.axoniq.framework.workflow.runtime.test.fixture.Phase

self

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

fixture

protected WorkflowTestFixture<?,?> fixture

testDriver

protected WorkflowTestDriver testDriver

Constructor Details

Phase

public Phase()

Method Details

initialize

protected void initialize(WorkflowTestFixture<?,?> fixture,
 WorkflowTestDriver testDriver)

Initializes this phase with the owning fixture and the shared test driver.

The fixture calls this during construction so both phases operate on the same underlying workflow runtime and testing state.

Parameters:

fixture - owning workflow test fixture

testDriver - shared workflow test driver

executionExists

public Then.Phase executionExists()

Waits until any active workflow execution exists.

Returns:

this phase for fluent chaining

executionExists

public Then.Phase executionExists(Predicate<WorkflowExecution> predicate)

Waits until an active workflow execution matching the predicate exists.

If exactly one execution matches, it becomes the selected execution for subsequent assertions.

Parameters:

predicate - predicate used to select matching executions

Returns:

this phase for fluent chaining

historyExists

public Then.Phase historyExists(Predicate<WorkflowHistory> predicate)

Waits until a workflow history matching the predicate exists.

If exactly one history matches, it becomes the selected history for subsequent assertions.

Parameters:

predicate - predicate used to select matching histories

Returns:

this phase for fluent chaining

historyExists

public Then.Phase historyExists(String workflowId)

Waits until a workflow history exists for the given workflow id.

Parameters:

workflowId - workflow id to find

Returns:

this phase for fluent chaining

historyExists

public Then.Phase historyExists(WorkflowStatus workflowStatus)

Waits until at least one workflow history exists and has the given status.

Parameters:

workflowStatus - expected workflow status

Returns:

this phase for fluent chaining

noExecution

public Then.Phase noExecution()

Asserts that no active workflow execution is present.

Returns:

this phase for fluent chaining

noHistory

public Then.Phase noHistory()

Asserts that no workflow history is recorded.

Returns:

this phase for fluent chaining

stop

public void stop()

Shuts down the test driver and all services.