require 'rubygems'
require 'eventmachine'
require 'yajl'
require 'em-http'
require 'uri'
 
EventMachine.run {
    body = ''
    on_body = lambda { |chunk|
        chunk.split(/\n/).each { |json|
            data = Yajl::Parser.new.parse(json)
            puts "#{data['user']['name']}: #{data['text']}"
        }
    }
    http = EventMachine::HttpRequest.new(URI.parse('http://stream.twitter.com/track.json')).post(
        :query => {'track' => 'dopplr'}, 
        :head => {'authorization' => ['user', 'pass']},
        :on_response => on_body)
}