class RubyEventStore::ImmediateAsyncDispatcher
Public Class Methods
new(scheduler:)
click to toggle source
# File lib/ruby_event_store/immediate_async_dispatcher.rb, line 5 def initialize(scheduler:) @scheduler = scheduler end
Public Instance Methods
call(subscriber, _, record)
click to toggle source
# File lib/ruby_event_store/immediate_async_dispatcher.rb, line 9 def call(subscriber, _, record) @scheduler.call(subscriber, record) end
verify(subscriber)
click to toggle source
# File lib/ruby_event_store/immediate_async_dispatcher.rb, line 13 def verify(subscriber) @scheduler.verify(subscriber) end