Module: Faye::Publisher
Instance Method Summary collapse
- #add_subscriber(event_type, listener) ⇒ Object
- #count_subscribers(event_type) ⇒ Object
- #publish_event(event_type, *args) ⇒ Object
- #remove_subscriber(event_type, listener) ⇒ Object
- #remove_subscribers ⇒ Object
Instance Method Details
#add_subscriber(event_type, listener) ⇒ Object
9 10 11 12 13 |
# File 'lib/faye/mixins/publisher.rb', line 9 def add_subscriber(event_type, listener) @subscribers ||= {} list = @subscribers[event_type] ||= [] list << listener end |
#count_subscribers(event_type) ⇒ Object
4 5 6 7 |
# File 'lib/faye/mixins/publisher.rb', line 4 def count_subscribers(event_type) return 0 unless @subscribers and @subscribers[event_type] @subscribers[event_type].size end |
#publish_event(event_type, *args) ⇒ Object
26 27 28 29 30 31 |
# File 'lib/faye/mixins/publisher.rb', line 26 def publish_event(event_type, *args) return unless @subscribers and @subscribers[event_type] @subscribers[event_type].each do |listener| listener.call(*args) end end |
#remove_subscriber(event_type, listener) ⇒ Object
15 16 17 18 19 20 |
# File 'lib/faye/mixins/publisher.rb', line 15 def remove_subscriber(event_type, listener) return unless @subscribers and @subscribers[event_type] return @subscribers.delete(event_type) unless listener @subscribers[event_type].delete_if(&listener.method(:==)) end |
#remove_subscribers ⇒ Object
22 23 24 |
# File 'lib/faye/mixins/publisher.rb', line 22 def remove_subscribers @subscribers = {} end |