Class: RubyEventStore::InstrumentedDispatcher

Inherits:
Object
  • Object
show all
Defined in:
lib/ruby_event_store/instrumented_dispatcher.rb

Instance Method Summary collapse

Constructor Details

#initialize(dispatcher, instrumentation) ⇒ InstrumentedDispatcher

Returns a new instance of InstrumentedDispatcher.



3
4
5
6
 
# File 'lib/ruby_event_store/instrumented_dispatcher.rb', line 3

def initialize(dispatcher, instrumentation)
  @dispatcher = dispatcher
  @instrumentation = instrumentation
end

Instance Method Details

#call(subscriber, event, serialized_event) ⇒ Object 



8
9
10
11
12
 
# File 'lib/ruby_event_store/instrumented_dispatcher.rb', line 8

def call(subscriber, event, serialized_event)
  instrumentation.instrument("call.dispatcher.rails_event_store", event: event, subscriber: subscriber) do
    dispatcher.call(subscriber, event, serialized_event)
  end
end

#verify(subscriber) ⇒ Object 



14
15
16
 
# File 'lib/ruby_event_store/instrumented_dispatcher.rb', line 14

def verify(subscriber)
  dispatcher.verify(subscriber)
end