From 24af00f6a7f624feda4b6aaceb4c5b0fa6f536d6 Mon Sep 17 00:00:00 2001 From: Aylur Date: Thu, 22 Aug 2024 02:14:36 +0200 Subject: feat: async Process.exec the exec_async function was not truly async but a signal based one --- src/process.vala | 32 +++++++++++++------------------- 1 file changed, 13 insertions(+), 19 deletions(-) (limited to 'src/process.vala') diff --git a/src/process.vala b/src/process.vala index 86e3ff6..073fe93 100644 --- a/src/process.vala +++ b/src/process.vala @@ -94,32 +94,26 @@ public class Astal.Process : Object { return Process.execv(argv); } - public Process.exec_asyncv(string[] cmd) throws Error { - Object(argv: cmd); - process = new Subprocess.newv(cmd, + public static async string exec_asyncv(string[] cmd) throws Error { + var process = new Subprocess.newv( + cmd, SubprocessFlags.STDERR_PIPE | SubprocessFlags.STDOUT_PIPE ); - process.communicate_utf8_async.begin(null, null, (_, res) => { - string err_str, out_str; - try { - process.communicate_utf8_async.end(res, out out_str, out err_str); - if (process.get_successful()) - stdout(out_str.strip()); - else - stderr(err_str.strip()); - } catch (Error err) { - printerr("%s\n", err.message); - } finally { - dispose(); - } - }); + string err_str, out_str; + yield process.communicate_utf8_async(null, null, out out_str, out err_str); + var success = process.get_successful(); + process.dispose(); + if (success) + return out_str.strip(); + else + throw new IOError.FAILED(err_str.strip()); } - public static Process exec_async(string cmd) throws Error { + public static async string exec_async(string cmd) throws Error { string[] argv; Shell.parse_argv(cmd, out argv); - return new Process.exec_asyncv(argv); + return yield exec_asyncv(argv); } } -- cgit v1.2.3