Sha256: b94c22ed140d59b13d8ce9e777f50cb8fc69d85d08b76644c94e9b78dc2db90e

Contents?: true

Size: 184 Bytes

Versions: 9

Compression:

Stored size: 184 Bytes

Contents

clients = {}

Juggernaut.subscribe do |event, data|
  case event
  when :subscribe
    clients[data.session_id] = data
  when :unsubscribe
    clients.delete(data.session_id)
  end
end

Version data entries

9 entries across 9 versions & 2 rubygems

Version Path
juggernaut-kafka-2.1.2 examples/roster.rb
juggernaut-2.1.1 examples/roster.rb
juggernaut-2.1.0 examples/roster.rb
juggernaut-2.0.4 examples/roster.rb
juggernaut-2.0.3 examples/roster.rb
juggernaut-2.0.2 examples/roster.rb
juggernaut-2.0.1 examples/roster.rb
juggernaut-2.0.0 examples/roster.rb
juggernaut-2.0.0.beta3 examples/roster.rb