class EventMachine::Channel

def push(*items)

Add items to the channel, which are pushed out to all subscribers. 
def push(*items)
  items = items.dup
  EM.schedule { items.each { |i| @subs.values.each { |s| s.call i } } }
end