class RubyEventStore::Subscriptions::ThreadGlobalSubscriptions
Public Class Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 95 def initialize @subscriptions = Concurrent::ThreadLocalVar.new([]) end
Public Instance Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 99 def add(subscription) @subscriptions.value += [subscription] -> { @subscriptions.value -= [subscription] } end
Source
# File lib/ruby_event_store/subscriptions.rb, line 104 def all_for(_topic) @subscriptions.value end