class ThriftServer::Publisher

Attributes

listeners[R]

Public Class Methods

new() click to toggle source
# File lib/thrift_server/publisher.rb, line 11
def initialize
  @listeners = [ ]
end

Public Instance Methods

publish(event, *args) click to toggle source
# File lib/thrift_server/publisher.rb, line 19
def publish(event, *args)
  listeners.each do |listener|
    listener.send(event, *args) if listener.respond_to? event
  end
end
subscribe(object) click to toggle source
# File lib/thrift_server/publisher.rb, line 15
def subscribe(object)
  listeners << object
end