Here's the result of my experiment:
from tornado.httpclient import HTTPClient, HTTPRequest import simplejson def handle_tweet_stream(response): try: # Print the parsed twitter stream. print simplejson.loads(response) except ValueError: return print if __name__ == '__main__': req = HTTPRequest( "http://stream.twitter.com/1/statuses/filter.json", body='track=google', method = "POST", auth_username = "username", auth_password = "xxxxxxx", streaming_callback=handle_tweet_stream) client = HTTPClient() client.fetch(req)