Class: RubyEventStore::ImmediateAsyncDispatcher

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

Instance Method Summary collapse

Constructor Details

#initialize(scheduler:) ⇒ ImmediateAsyncDispatcher

Returns a new instance of ImmediateAsyncDispatcher.


5
6
7
# File 'lib/ruby_event_store/immediate_async_dispatcher.rb', line 5

def initialize(scheduler:)
  @scheduler = scheduler
end

Instance Method Details

#call(subscriber, _, record) ⇒ Object


9
10
11
# File 'lib/ruby_event_store/immediate_async_dispatcher.rb', line 9

def call(subscriber, _, record)
  @scheduler.call(subscriber, record)
end

#verify(subscriber) ⇒ Object


13
14
15
# File 'lib/ruby_event_store/immediate_async_dispatcher.rb', line 13

def verify(subscriber)
  @scheduler.verify(subscriber)
end