Class: EventSourcing::Event::Bus::Reference

Inherits:
Concurrent::Actor::Reference
  • Object
show all
Defined in:
lib/event_sourcing/event/bus/reference.rb

Instance Method Summary collapse

Instance Method Details

#get_stream(id) ⇒ Object 



13
14
15
 
# File 'lib/event_sourcing/event/bus/reference.rb', line 13

def get_stream(id)
  store.get_stream(id)
end

#publish(events) ⇒ Object 



9
10
11
 
# File 'lib/event_sourcing/event/bus/reference.rb', line 9

def publish(events)
  publisher.publish(events)
end