wow-test/me.ahoo.wow.test.saga.stateless/ExpectedResult

ExpectedResult

data class ExpectedResult<T : Any>(val exchange: DomainEventExchange<*>, val processor: T, val commandStream: CommandStream?, val error: Throwable? = null) : StatelessSagaExpecter<T, ExpectedResult<T>>

Represents the expected result of a stateless saga processing operation.

This data class encapsulates the outcome of processing a domain event through a stateless saga, including the event exchange, processor, generated commands, and any errors that occurred.

Parameters

The type of the saga processor.

Constructors

ExpectedResult

constructor(exchange: DomainEventExchange<*>, processor: T, commandStream: CommandStream?, error: Throwable? = null)

Properties

commandStream

val commandStream: CommandStream?

The stream of commands generated by the saga, or null if none.

error

val error: Throwable?

Any error that occurred during processing, or null if successful.

exchange

val exchange: DomainEventExchange<*>

The domain event exchange that triggered the saga processing.

hasError

val hasError: Boolean

Indicates whether an error occurred during saga processing.

processor

val processor: T

The saga processor instance that handled the event.

Functions

expect

open override fun expect(expected: ExpectedResult<T>.() -> Unit): ExpectedResult<T>

Sets expectations on the expected result using a lambda.

expectCommand

open fun <C : Any> expectCommand(expected: CommandMessage<C>.() -> Unit): ExpectedResult<T>

Sets expectations on the first command in the command stream.

expectCommandBody

open fun <C : Any> expectCommandBody(expected: C.() -> Unit): ExpectedResult<T>

Sets expectations on the body of the first command.

expectCommandCount

open fun expectCommandCount(expected: Int): ExpectedResult<T>

Expects a specific number of commands in the command stream.

expectCommandIterator

open fun expectCommandIterator(expected: CommandIterator.() -> Unit): ExpectedResult<T>

Sets expectations on a command iterator created from the command stream.

expectCommandStream

open fun expectCommandStream(expected: CommandStream.() -> Unit): ExpectedResult<T>

Sets expectations on the command stream, ensuring no error occurred first.

expectCommandType

open fun expectCommandType(vararg expected: Class<*>): ExpectedResult<T>

Expects commands of specific types in order (Java Class version).

open fun expectCommandType(vararg expected: KClass<*>): ExpectedResult<T>

Expects commands of specific types in order.

expectError

open fun expectError(): ExpectedResult<T>

Expects that an error occurred during saga processing.

open fun <E : Throwable> expectError(expected: E.() -> Unit): ExpectedResult<T>

Expects a specific error with custom assertions.

expectErrorType

open fun <E : Throwable> expectErrorType(expected: Class<E>): ExpectedResult<T>

Expects an error of a specific type (Java Class version).

open fun <E : Throwable> expectErrorType(expected: KClass<E>): ExpectedResult<T>

Expects an error of a specific type.

expectNoCommand

open fun expectNoCommand(): ExpectedResult<T>

Expects that no commands were generated by the saga.

expectNoError

open fun expectNoError(): ExpectedResult<T>

Expects that no error occurred during saga processing.