Module: Replay::Subscriptions

Defined in:
lib/replay/subscriptions.rb

Instance Method Summary collapse

Instance Method Details

#add_subscriber(subscriber) ⇒ Object 



11
12
13
 
# File 'lib/replay/subscriptions.rb', line 11

def add_subscriber(subscriber)
  subscription_manager.add_subscriber(subscriber)
end

#published(stream_id, event, metadata) ⇒ Object 



15
16
17
 
# File 'lib/replay/subscriptions.rb', line 15

def published(stream_id, event, metadata)
  @subscription_manager.notify_subscribers(stream_id, event, metadata)
end

#subscription_manager ⇒ Object 



3
4
5
 
# File 'lib/replay/subscriptions.rb', line 3

def subscription_manager
  @subscription_manager ||= Replay::SubscriptionManager.new(Replay.logger)
end

#subscription_manager=(sm) ⇒ Object 



7
8
9
 
# File 'lib/replay/subscriptions.rb', line 7

def subscription_manager=(sm)
  @subscription_manager = sm
end