Class: ThriftServer::Publisher

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Includes:
Enumerable
Defined in:
lib/thrift_server/publisher.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Publisher

Returns a new instance of Publisher.



11
12
13
 
# File 'lib/thrift_server/publisher.rb', line 11

def initialize
  @listeners = [ ]
end

Instance Attribute Details

#listeners ⇒ Object (readonly)

Returns the value of attribute listeners.



9
10
11
 
# File 'lib/thrift_server/publisher.rb', line 9

def listeners
  @listeners
end

Instance Method Details

#publish(event, *args) ⇒ Object 



19
20
21
22
23
 
# 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) ⇒ Object 



15
16
17
 
# File 'lib/thrift_server/publisher.rb', line 15

def subscribe(object)
  listeners << object
end