diff options
Diffstat (limited to 'src/core/utils/AsyncUtils.cpp')
| -rw-r--r-- | src/core/utils/AsyncUtils.cpp | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/src/core/utils/AsyncUtils.cpp b/src/core/utils/AsyncUtils.cpp index 545c9ce3..4de7fa1e 100644 --- a/src/core/utils/AsyncUtils.cpp +++ b/src/core/utils/AsyncUtils.cpp @@ -67,4 +67,25 @@ void RunGpgOperaAsync(GpgOperaRunnable runnable, GpgOperationCallback callback, .GetTaskRunner(Thread::TaskRunnerGetter::kTaskRunnerType_GPG) ->PostTask(task); } + +void RunIOOperaAsync(OperaRunnable runnable, OperationCallback callback, + const std::string& operation) { + auto* task = new Thread::Task( + [=](const DataObjectPtr& data_object) -> int { + auto custom_data_object = TransferParams(); + GpgError err = runnable(custom_data_object); + + data_object->Swap({err, custom_data_object}); + return 0; + }, + operation, TransferParams(), + [=](int, const DataObjectPtr& data_object) { + callback(ExtractParams<GFError>(data_object, 0), + ExtractParams<DataObjectPtr>(data_object, 1)); + }); + + Thread::TaskRunnerGetter::GetInstance() + .GetTaskRunner(Thread::TaskRunnerGetter::kTaskRunnerType_IO) + ->PostTask(task); +} } // namespace GpgFrontend
\ No newline at end of file |