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

CommandStream

interface CommandStream : Iterable<CommandMessage<*>>

Inheritors

DefaultCommandStream

Properties

abstract val domainEventId: String

abstract val size: Int

Functions

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

abstract operator 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<*>>