mloughran

require 'em-hiredis'

EM.run {
  require 'em-hiredis'
  redis = EM::Hiredis.connect
  
  # If you pass a block to subscribe it will be called whenever a message
  # is received on this channel
  redis.pubsub.subscribe('foo') { |msg|
    p [:received_foo, msg]