Class: Sourced::Sync::SyncReactor

Inherits:
SimpleDelegator
  • Object
show all
Defined in:
lib/sourced/sync.rb

Instance Method Summary collapse

Instance Method Details

#call(_state, _command, events) ⇒ Object



32
33
34
# File 'lib/sourced/sync.rb', line 32

def call(_state, _command, events)
  handle_events(events)
end

#handle_events(events) ⇒ Object



28
29
30
# File 'lib/sourced/sync.rb', line 28

def handle_events(events)
  Router.handle_and_ack_events_for_reactor(__getobj__, events)
end