Package-level declarations

Abstract base class for wait strategies that wait for a specific stage after command processing is complete. This class ensures that both PROCESSED stage and the target stage are completed before considering the wait strategy satisfied. It's designed for stages that occur after the basic command processing.

Wait strategy that waits for domain events to be handled by event processors. This strategy completes when both command processing and event handling are finished. Optionally filters by specific function criteria if provided.

Abstract base class for wait strategies that wait for specific function execution within a processing stage. This class extends WaitingForAfterProcessed and adds function-based filtering capabilities. Subclasses can specify which functions within their stage they want to wait for.

Wait strategy that waits for command processing to complete. This is the most basic wait strategy that completes when the aggregate has finished processing the command and generated any domain events.

Wait strategy that waits for projections to be updated based on command-generated events. This strategy completes when both command processing and projection updates are finished. Only completes on the final projection signal to ensure all projections are updated. Optionally filters by specific projection function criteria if provided.

Wait strategy that waits for sagas to handle command-generated events. This strategy completes when both command processing and saga event handling are finished. Sagas may generate additional commands as part of their processing. Optionally filters by specific saga function criteria if provided.

Wait strategy that completes immediately when the command is sent to the bus. This is the most minimal wait strategy - it doesn't wait for any processing. Supports void commands since no processing results are expected.

Wait strategy that waits for aggregate snapshots to be generated. This strategy completes when both command processing and snapshot creation are finished. Snapshots are used for performance optimization in high-throughput scenarios.

Single command waiting strategy based on command execution phase