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