class RubyEventStore::ROM::Memory::Relations::Events
Public Instance Methods
by_pk(id)
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 33 def by_pk(id) restrict(id: id) end
create_changeset(tuples)
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 16 def create_changeset(tuples) events.changeset(Changesets::CreateEvents, tuples) end
exist?()
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 37 def exist? one? end
for_stream_entries(_assoc, stream_entries)
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 29 def for_stream_entries(_assoc, stream_entries) restrict(id: stream_entries.map { |e| e[:event_id] }) end
insert(tuple)
click to toggle source
Calls superclass method
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 24 def insert(tuple) verify_uniquness!(tuple) super end
pluck(name)
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 41 def pluck(name) map { |e| e[name] } end
update_changeset(tuples)
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 20 def update_changeset(tuples) events.changeset(Changesets::UpdateEvents, tuples) end
Private Instance Methods
verify_uniquness!(tuple)
click to toggle source
# File lib/ruby_event_store/rom/adapters/memory/relations/events.rb, line 47 def verify_uniquness!(tuple) return unless by_pk(tuple[:id]).exist? raise TupleUniquenessError.for_event_id(tuple[:id]) end