class

Posse::Pipelines::Pipeline

Inherits Reference < Object

Constants

Log = ::Log.for(self)

Constructors

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

Instance methods

aggregate_id
Source
aggregate_id=(aggregate_id : String)
Source
assign(key : String, value : T) : self forall T
Source
assigns
Source
command
Source
command=(command : Posse::Commands::Command)
Source
exception
Source
exception=(exception : Exception | Nil)
Source
fetch(key : String, type : T.class) : T forall T
Source
fetch?(key : String, type : T.class) : T | Nil forall T
Source
halt
Source
halted?
Source
response
Source
response=(response : Posse::Commands::Result | Nil)
Source