rawr.py

import sys
import os
import fcntl
import gevent
from gevent import socket, queue

if __name__ == "__main__":
    fcntl.fcntl(sys.stdin, fcntl.F_SETFL, os.O_NONBLOCK)
    q = queue.Queue()
    def rea():
        buff = ''
        while True:
            socket.wait_read(sys.stdin.fileno())
            buff += sys.stdin.read()
            while '\n' in buff:
                line, buff = buff.split('\n', 1)
                q.put(line)
    def pri():
        for line in q:
            print 'stdin::', line
    g = gevent.spawn(rea)
    g2 = gevent.spawn(pri)
    gevent.joinall([g, g2])