class

Posse::Pipelines::Pipeline

Inherits Reference < Object

Constants

Log = ::Log.for(self)

Constructors

new(command : Posse::Commands::Command, aggregate_id : String)

Instance methods

aggregate_id

aggregate_id=(aggregate_id : String)

assign(key : String, value : T) : self forall T

assigns

command

command=(command : Posse::Commands::Command)

exception

exception=(exception : Exception | Nil)

fetch(key : String, type : T.class) : T forall T

fetch?(key : String, type : T.class) : T | Nil forall T

halt

halted?

response

response=(response : Posse::Commands::Result | Nil)