Posse::EventStore::InMemory

Log = ::Log.for(self)

acknowledge(handler_name : String, version : Int64) : Nil

append(stream_id : String, expected_version : Int64, events : Array(Posse::Events::Event), consistency : Posse::Commands::Consistency::Any = Posse::Commands::Consistency::Kind::Strong) : Int64

load(stream_id : String, after_version : Int64) : Array(Posse::Events::Event)

load(stream_id : String) : Array(Posse::Events::Event)

subscribe(subscriber_name : String, &block : Posse::Events::Event, Hash(String, JSON::Any) -> Nil) : Nil

wait_for_consistency(consistency : Posse::Commands::Consistency::Any, target_version : Int64, timeout : Time::Span = 5.seconds) : Nil