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

DefaultCommandStream

data class DefaultCommandStream(val domainEventId: String, commands: List<CommandMessage<*>>) : CommandStream, Iterable<CommandMessage<*>>

Constructors

DefaultCommandStream

constructor(domainEventId: String, commands: List<CommandMessage<*>>)

Properties

open override val domainEventId: String

open override val size: Int

Functions

open fun forEach(p0: Consumer<in CommandMessage<*>>)

open operator override fun iterator(): Iterator<CommandMessage<*>>

mergeAnnotations

fun Iterable<Annotation>.mergeAnnotations(scanned: MutableList<Annotation> = mutableListOf()): List<Annotation>

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

open fun spliterator(): Spliterator<CommandMessage<*>>