em-channel for pub-sub

test-em-channel-pubsub.rb

require 'rubygems'
require 'eventmachine'
EM.run{
    channel = EM::Channel.new
    sid = channel.subscribe{ |topic,msg| p [topic, msg] }
    channel.push(['topic',{'key1'=>'value1'}])
    channel.push({'topic'=>'test','msg'=>{'a'=>'b'}})
    channel.unsubscribe(sid)
    EM.stop
 }