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