Class: Faye::Channel::Set
- Inherits:
-
Object
- Object
- Faye::Channel::Set
- Defined in:
- lib/faye/protocol/channel.rb
Instance Method Summary collapse
- #distribute_message(message) ⇒ Object
- #has_subscription?(name) ⇒ Boolean
-
#initialize ⇒ Set
constructor
A new instance of Set.
- #keys ⇒ Object
- #remove(name) ⇒ Object
- #subscribe(names, callback) ⇒ Object
- #unsubscribe(name, callback) ⇒ Object
Constructor Details
#initialize ⇒ Set
Returns a new instance of Set.
78 79 80 |
# File 'lib/faye/protocol/channel.rb', line 78 def initialize @channels = {} end |
Instance Method Details
#distribute_message(message) ⇒ Object
113 114 115 116 117 118 119 |
# File 'lib/faye/protocol/channel.rb', line 113 def () channels = Channel.(['channel']) channels.each do |name| channel = @channels[name] channel.trigger(:message, ['data']) if channel end end |
#has_subscription?(name) ⇒ Boolean
90 91 92 |
# File 'lib/faye/protocol/channel.rb', line 90 def has_subscription?(name) @channels.has_key?(name) end |
#keys ⇒ Object
82 83 84 |
# File 'lib/faye/protocol/channel.rb', line 82 def keys @channels.keys end |
#remove(name) ⇒ Object
86 87 88 |
# File 'lib/faye/protocol/channel.rb', line 86 def remove(name) @channels.delete(name) end |
#subscribe(names, callback) ⇒ Object
94 95 96 97 98 99 |
# File 'lib/faye/protocol/channel.rb', line 94 def subscribe(names, callback) names.each do |name| channel = @channels[name] ||= Channel.new(name) channel.bind(:message, &callback) if callback end end |
#unsubscribe(name, callback) ⇒ Object
101 102 103 104 105 106 107 108 109 110 111 |
# File 'lib/faye/protocol/channel.rb', line 101 def unsubscribe(name, callback) channel = @channels[name] return false unless channel channel.unbind(:message, &callback) if channel.unused? remove(name) true else false end end |