class Connection(object):
    def __init__(self, connection):
        clients.append(self)
        self.stream = iostream.IOStream(connection)
        self.read()
    def read(self):[s][/s]
        self.stream.read_until('\r\n', self.eol_callback)
    def eol_callback(self, data):
        print data
        for c in clients:[s][/s]
            try:
                c.stream.write(str(len(clients))+'\r\n')
            except:
                clients.remove(c)
        self.read()

    def _on_read_line(self, data):
        logging.info('read a new line from %s', self.address)
        for stream in self.stream_set:
            [b]stream.write(data, self._on_write_complete)[/b] 
 
    def _on_write_complete(self):
        logging.info('write a line to %s', self.address)
        if not self.stream.reading():
            [b]self.stream.read_until('\n', self._on_read_line)[/b]