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