Method List
-
#<< Estore::Connection::Buffer
-
#append Estore::Session
-
#batch_completed Estore::Commands::ReadForward
-
#call Estore::Commands::ReadForward
-
#call Estore::Commands::Append
-
#call Estore::Commands::ReadBatch
-
#call Estore::Commands::Ping
-
#call Estore::Commands::Subscription
-
#close Estore::Session
-
#close Estore::Connection
-
#close Estore::Commands::Subscription
-
command_name Estore::Connection
-
#completed Estore::Commands::ReadBatch
-
#completed Estore::Commands::Append
-
#consume_packages Estore::Connection::Buffer
-
#correlation_id Estore::Commands::Promise
-
decode Estore::Package
-
#discard_bytes Estore::Connection::Buffer
-
#dispatch Estore::ConnectionContext
-
#empty? Estore::ConnectionContext
-
encode Estore::Package
-
encode_uuid Estore::Package
-
#enqueue Estore::Commands::Subscription
-
#error Estore::Commands::ReadStreamForward
-
#event_appeared Estore::Commands::CatchUpSubscription
-
#event_appeared Estore::Commands::LiveSubscription
-
#handle Estore::Commands::Command::ClassMethods
-
#handle Estore::Connection::Buffer
-
#handle Estore::Commands::Command
-
#handle Estore::Commands::Ping
-
#host Estore::Connection
-
#initialize Estore::Commands::CatchUpSubscription
-
#initialize Estore::Connection
-
#initialize Estore::Commands::Command
-
#initialize Estore::Session
-
#initialize Estore::Commands::Subscription
-
#initialize Estore::Commands::ReadBatch
-
#initialize Estore::Connection::Buffer
-
#initialize Estore::Commands::Promise
-
#initialize Estore::Commands::Append
-
#initialize Estore::Commands::ReadForward
-
#initialize Estore::ConnectionContext
-
#keep_reading Estore::Commands::ReadForward
-
#on_error Estore::ConnectionContext
-
#on_event Estore::Commands::Subscription
-
#original_event Estore::OriginalEventMixin
-
#original_event_number Estore::OriginalEventMixin
-
#original_stream_id Estore::OriginalEventMixin
-
#parse Estore::Connection::Buffer
-
parse_uuid Estore::Package
-
#ping Estore::Session
-
#port Estore::Connection
-
prefix_with_length Estore::Package
-
#promise Estore::Commands::Command
-
#read Estore::Commands::ReadStreamForward
-
#read Estore::Session
-
#read_batch Estore::Session
-
#read_forward Estore::Session
-
#read_package Estore::Connection::Buffer
-
#register Estore::ConnectionContext
-
#register! Estore::Commands::Command
-
#reject! Estore::Commands::Command
-
#remove Estore::ConnectionContext
-
#remove! Estore::Commands::Command
-
reverse_lookup_table Estore::Connection
-
#start Estore::Commands::Subscription
-
#start Estore::Commands::CatchUpSubscription
-
#subscription Estore::Session
-
#switch_to_live Estore::Commands::CatchUpSubscription
-
#unprocessed_events Estore::Commands::CatchUpSubscription
-
#uuid Estore::Commands::Command
-
#wait Estore::Commands::Promise
-
#worker_loop Estore::Commands::Subscription
-
#write Estore::Connection
-
#write Estore::Commands::Command