Class: RubyEventStore::ImmediateAsyncDispatcher

Inherits:

Object

• Object
• RubyEventStore::ImmediateAsyncDispatcher

Defined in:

lib/ruby_event_store/immediate_async_dispatcher.rb

Instance Method Summary

• #call(subscriber, _, record) ⇒ Object
• #initialize(scheduler:) ⇒ ImmediateAsyncDispatcher constructor

  A new instance of ImmediateAsyncDispatcher.

• #verify(subscriber) ⇒ Object

Constructor Details

#initialize(scheduler:) ⇒ ImmediateAsyncDispatcher

Returns a new instance of ImmediateAsyncDispatcher.

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

def initialize(scheduler:)
  @scheduler = scheduler
end

Instance Method Details

#call(subscriber, _, record) ⇒ Object

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

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

#verify(subscriber) ⇒ Object

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

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