class RubyEventStore::Subscriptions::GlobalSubscriptions

Public Class Methods

new() click to toggle source
# File lib/ruby_event_store/subscriptions.rb, line 65
def initialize
  @subscriptions = []
end

Public Instance Methods

add(subscription) click to toggle source
# File lib/ruby_event_store/subscriptions.rb, line 69
def add(subscription)
  @subscriptions << subscription
  -> { @subscriptions.delete(subscription) }
end
all_for(_event_type) click to toggle source
# File lib/ruby_event_store/subscriptions.rb, line 74
def all_for(_event_type)
  @subscriptions
end