ConsoleFlush.cs

using System.Threading;
using System.Threading.Tasks;
using Waher.Runtime.Queue;
 
namespace Waher.Runtime.Console.Worker
{
    public class ConsoleFlush : WorkItem
    {
        private readonly TaskCompletionSource<bool> result;
        private readonly bool terminate;
 
        public ConsoleFlush(bool Terminate, TaskCompletionSource<bool> Result)
        {
            this.terminate = Terminate;
            this.result = Result;
        }
 
        public override async Task Execute(CancellationToken Cancel)
        {
            await System.Console.Out.FlushAsync();
 
            if (this.terminate)
                _ = Task.Run(async () => await ConsoleWorker.Terminate());
 
            this.result.TrySetResult(true);
        }
    }
}