tornado echo server

echo_server.py

from tornado.tcpserver import TCPServer
from tornado.ioloop import IOLoop
from uuid import uuid4


class EchoConnection(object):

    def __init__(self, stream, address):
        self.address = address
        self.stream = stream
        self.read()

    def read(self):
        self.stream.read_until('\r\n', self.on_read)

    def on_read(self, data):
        self.stream.write(data)
        self.read()


class EchoTCPServer(TCPServer):

    def handle_stream(self, stream, address):        
        EchoConnection(stream, address)


if __name__=="__main__":
    server = EchoTCPServer()
    server.listen(8000)
    IOLoop.instance().start()