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