class RubyEventStore::SpecificationReader
Used for fetching events based on given query specification.
Attributes
Public Class Methods
Source
# File lib/ruby_event_store/specification_reader.rb, line 8 def initialize(repository, mapper) @repository = repository @mapper = mapper end
@api private @private
Public Instance Methods
Source
# File lib/ruby_event_store/specification_reader.rb, line 28 def count(specification_result) repository.count(specification_result) end
@api private @private
Source
# File lib/ruby_event_store/specification_reader.rb, line 22 def each(specification_result) repository.read(specification_result).each { |batch| yield map(batch) } end
@api private @private
Source
# File lib/ruby_event_store/specification_reader.rb, line 15 def one(specification_result) record = repository.read(specification_result) map([record]).first if record end
@api private @private
Private Instance Methods
Source
# File lib/ruby_event_store/specification_reader.rb, line 34 def map(records) mapper.records_to_events(records) end