BadTaskUtils.cs

Go to the documentation of this file.

using BadScript2.Runtime.Error;
using BadScript2.Runtime.Objects;
using BadScript2.Utility;
 
namespace BadScript2.Interop.Common.Task;
 
public static class BadTaskUtils
{
    public static BadInteropRunnable WaitForTask<T>(Task<T> t, Func<T, BadObject> onComplete)
    {
        BadInteropRunnable? runnable = null;
 
        runnable = new BadInteropRunnable(InnerWaitForTask());
 
        return runnable;
 
        IEnumerator<BadObject> InnerWaitForTask()
        {
            while (t is { IsCanceled: false, IsCompleted: false, IsFaulted: false })
            {
                yield return BadObject.Null;
            }
 
            if (t.IsCompletedSuccessfully())
            {
                // ReSharper disable once AccessToModifiedClosure
                runnable!.SetReturn(onComplete(t.Result));
            }
            else
            {
                throw new BadRuntimeException("Task Failed");
            }
        }
    }
 
 
    public static BadInteropRunnable WaitForTask(System.Threading.Tasks.Task t)
    {
        BadInteropRunnable? runnable = null;
 
        runnable = new BadInteropRunnable(InnerWaitForTask());
 
        return runnable;
 
        IEnumerator<BadObject> InnerWaitForTask()
        {
            while (t is { IsCanceled: false, IsCompleted: false, IsFaulted: false })
            {
                yield return BadObject.Null;
            }
 
            if (t.IsCompletedSuccessfully())
            {
                // ReSharper disable once AccessToModifiedClosure
                runnable!.SetReturn(BadObject.Null);
            }
            else
            {
                throw new BadRuntimeException("Task Failed");
            }
        }
    }
 
    public static BadInteropRunnable WaitForTask<T>(Task<T> t)
    {
        BadInteropRunnable? runnable = null;
 
        runnable = new BadInteropRunnable(InnerWaitForTask());
 
        return runnable;
 
        IEnumerator<BadObject> InnerWaitForTask()
        {
            while (t is { IsCanceled: false, IsCompleted: false, IsFaulted: false })
            {
                yield return BadObject.Null;
            }
 
            if (t.IsCompletedSuccessfully())
            {
                // ReSharper disable once AccessToModifiedClosure
                runnable!.SetReturn(BadObject.Wrap(t.Result));
            }
            else
            {
                throw new BadRuntimeException("Task Failed");
            }
        }
    }
}