class Operate::Pubsub::Registration

Registers a listener for an event(s).

Attributes

listener[R]
on[R]

Public Class Methods

new(listener, options) click to toggle source
# File lib/operate/pubsub/registration.rb, line 9
def initialize(listener, options)
  @listener = listener
  @on = Operate::Pubsub::Events.new options[:on]
end

Public Instance Methods

broadcast(event, *args) click to toggle source
# File lib/operate/pubsub/registration.rb, line 14
def broadcast(event, *args)
  listener.call(*args) if should_broadcast?(event)
end

Private Instance Methods

should_broadcast?(event) click to toggle source
# File lib/operate/pubsub/registration.rb, line 20
def should_broadcast?(event)
  on.include? event
end