def _flush_pipeline(self):
        self.io.flush_send()
        while True:
            try:
                reply = self.reply_queue.pop(0)
            except __HOLE__:
                return None
            reply.recv(self.io)
            if reply.is_error():
                self.last_error = reply
dataset/ETHPy150Open slimta/python-slimta/slimta/smtp/client.py/Client._flush_pipeline