def flush(self): if not len(self.out_buffer): return try: count = self.socket.send(self.out_buffer) self.out_buffer = self.out_buffer[count:] except: self.socket.close()