class RubyEventStore::LinkByEventType
Public Class Methods
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
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