gistfile1.txt

    while True:
        pollrc = ep.select(timeout=int(opts.read_timeout) if int(opts.read_timeout) > 0 else None)
        sys.stdout.flush()
        try:
            buf = sock.recv(4096, socket.MSG_DONTWAIT)
            rbuf += buf
            while True:
                sys.stdout.flush()
                rbuf = rbuf.lstrip()
#                f = open('/tmp/raw_' + str(i), 'wb')
#                f.write(rbuf)
#                f.close()
#                i += 1