module Estore::Commands::ReadStreamForward
Public Instance Methods
error(response)
click to toggle source
# File lib/estore/commands/read.rb, line 16 def error(response) case response.result when ReadStreamEventsCompleted::ReadStreamResult::AccessDenied :access_denied when ReadStreamEventsCompleted::ReadStreamResult::Error response.error ? response.error : 'No message given' else false end end
read(stream, from, limit)
click to toggle source
# File lib/estore/commands/read.rb, line 4 def read(stream, from, limit) msg = ReadStreamEvents.new( event_stream_id: stream, from_event_number: from, max_count: limit, resolve_link_tos: true, require_master: false ) write('ReadStreamEventsForward', msg) end