wow-core/me.ahoo.wow.saga.stateless/CommandStream

CommandStream

interface CommandStream : Iterable<CommandMessage<*>>

Represents a stream of command messages generated in response to a domain event in a stateless saga. This interface provides access to the commands that should be sent as part of the saga's reaction to an event.

Inheritors

DefaultCommandStream

Properties

domainEventId

abstract val domainEventId: String

The ID of the domain event that triggered this command stream.

size

abstract val size: Int

The number of command messages in this stream.

Functions

iterator

abstract operator fun iterator(): Iterator<CommandMessage<*>>

sortedByOrder

fun <T : Any> Iterable<T>.sortedByOrder(): List<T>

Sorts an iterable collection based on Order annotations and dependencies.