class RubyEventStore::LinkByEventType

Public Class Methods

new(event_store:, prefix: nil) click to toggle source
# File lib/ruby_event_store/link_by_metadata.rb, line 31
def initialize(event_store:, prefix: nil)
  @event_store = event_store
  @prefix = prefix || "$by_type_"
end

Public Instance Methods

call(event) click to toggle source
# File lib/ruby_event_store/link_by_metadata.rb, line 36
def call(event)
  @event_store.link([event.event_id], stream_name: "#{@prefix}#{event.event_type}")
end