class RailsEventSourcing::Dispatcher::ReactorSet
Contains sync and async reactors. Used to:
-
store reactors via Rules#register
-
return a set of matching reactors with Rules#for
Attributes
async[R]
sync[R]
Public Class Methods
new()
click to toggle source
# File lib/rails-event-sourcing/dispatcher.rb, line 69 def initialize @sync = Set.new @async = Set.new end
Public Instance Methods
add_async(reactors)
click to toggle source
# File lib/rails-event-sourcing/dispatcher.rb, line 78 def add_async(reactors) @async += reactors end
add_sync(reactors)
click to toggle source
# File lib/rails-event-sourcing/dispatcher.rb, line 74 def add_sync(reactors) @sync += reactors end