ProcessExtensions.cs

using System;
using System.Diagnostics;
using System.IO;
using System.Threading;
using System.Threading.Tasks;

namespace Turkey
{
    public static class ProcessRunner
    {
        public static async Task<int> RunAsync(ProcessStartInfo psi, Action<string> logger, CancellationToken token)
        {
            logger($"Executing {psi.FileName} with arguments {psi.Arguments} in working directory {psi.WorkingDirectory}");
            using var process = Process.Start(psi);
            await process.WaitForExitAsync(logger, token).ConfigureAwait(false);
            return process.ExitCode;
        }
    }

    public static class ProcessExtensions
    {
        public static async Task WaitForExitAsync(this Process process, Action<string> logger, CancellationToken token)
        {
            process.EnableRaisingEvents = true;
            bool captureOutput = true;
            DataReceivedEventHandler logToLogger = (sender, e) =>
            {
                if (e.Data != null)
                {
                    lock (logger)
                    {
                        if (captureOutput)
                        {
                            logger(e.Data);
                        }
                    }
                }
            };
            process.OutputDataReceived += logToLogger;
            process.BeginOutputReadLine();
            process.ErrorDataReceived += logToLogger;
            process.BeginErrorReadLine();

            try
            {
                await process.WaitForExitAsync(token).ConfigureAwait(false);

                logger($"Process Exit Code: {process.ExitCode}");
            }
            catch (OperationCanceledException)
            {
                lock (logger)
                {
                    captureOutput = false;
                }
                logger($"Process wait for exit cancelled.");

                try
                {
                    process.Kill(entireProcessTree: true);
                }
                catch
                { }

                throw;
            }
        }
    }
}