Sha256: d40f557ce297c0f6090cf5923944ab52b016b45a523525d34d54a4e1c8233302
Contents?: true
Size: 481 Bytes
Versions: 26
Compression:
Stored size: 481 Bytes
Contents
module Euston
module EventStore
module Dispatcher
class SynchronousDispatcher
def initialize persistence, &block
@persistence = persistence
@dispatch = block
end
def dispatch commit
@dispatch.call commit
@persistence.mark_commit_as_dispatched commit
end
def lookup
@persistence.get_undispatched_commits.each { |commit| dispatch commit }
end
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems