class RubyEventStore::Subscriptions::ThreadSubscriptions
Attributes
global[R]
local[R]
Public Class Methods
new()
click to toggle source
# File lib/ruby_event_store/subscriptions.rb, line 38 def initialize @local = ThreadLocalSubscriptions.new @global = ThreadGlobalSubscriptions.new end
Public Instance Methods
all_for(event_type)
click to toggle source
# File lib/ruby_event_store/subscriptions.rb, line 44 def all_for(event_type) [global, local].map { |r| r.all_for(event_type) }.reduce(&:+) end