def custom_command(self, command, arg=None):
        custom = Reply(command=command.upper())
        self.reply_queue.append(custom)

        if arg:
            command = b' '.join((command, arg))
        self.io.send_command(command)

        self._flush_pipeline()

        return custom
Whether or not the async operation has completed
dataset/ETHPy150Open slimta/python-slimta/slimta/smtp/client.py/Client.custom_command--crossover with--dataset/ETHPy150Open OneDrive/onedrive-sdk-python/src/onedrivesdk/async_operation_monitor.py/AsyncOperationMonitor.completed