def handle_write(self):
        with self._write_lock:
            try:
                data = self._write_queue.popleft()
            except __HOLE__:
                return
            sent = self.send(data)
            self.sent_protocol_bytes = True
            if sent < len(data):
                self._write_queue.appendleft(data[sent:])
dataset/ETHPy150Open hazelcast/hazelcast-python-client/hazelcast/reactor.py/AsyncoreConnection.handle_write