Class: Lyra::RailsEventStoreAdapter

Inherits:

Object

• Object
• Lyra::RailsEventStoreAdapter

Defined in:

lib/lyra/event_store_adapter.rb

Instance Method Summary

• #initialize ⇒ RailsEventStoreAdapter constructor

  A new instance of RailsEventStoreAdapter.

• #publish(event, stream_name:) ⇒ Object
• #read_all_streams ⇒ Object
• #read_stream(stream_name) ⇒ Object
• #subscribe(subscriber, to:) ⇒ Object

Constructor Details

#initialize ⇒ RailsEventStoreAdapter

Returns a new instance of RailsEventStoreAdapter.

# File 'lib/lyra/event_store_adapter.rb', line 21

def initialize
  @client = build_client
end

Instance Method Details

#publish(event, stream_name:) ⇒ Object

# File 'lib/lyra/event_store_adapter.rb', line 25

def publish(event, stream_name:)
  @client.publish(event, stream_name: stream_name)
end

#read_all_streams ⇒ Object

# File 'lib/lyra/event_store_adapter.rb', line 33

def read_all_streams
  @client.read.to_a
end

#read_stream(stream_name) ⇒ Object

# File 'lib/lyra/event_store_adapter.rb', line 29

def read_stream(stream_name)
  @client.read.stream(stream_name).to_a
end

#subscribe(subscriber, to:) ⇒ Object

# File 'lib/lyra/event_store_adapter.rb', line 37

def subscribe(subscriber, to:)
  @client.subscribe(subscriber, to: to)
end