require 'eventmachine'

class Actor
    def initialize(&cb)
        @channel = EM::Channel.new
        @sid = @channel.subscribe &cb
    end
    def << message
        @channel.push message
    end
    def die
        @channel.unsubscribe(@sid)
    end
end



EM::run {
    actor = Actor.new { |message| puts message }
    actor << "woot"
    EM::stop_event_loop
}