ScheduledEvent.cs

using System;
using System.Threading.Tasks;
using Waher.Events;
 
namespace Waher.Runtime.Timing
{
    internal class ScheduledEvent
    {
        private readonly DateTime when;
        private readonly Action<object> eventMethod;
        private readonly object state;
 
        public ScheduledEvent(DateTime When, Action<object> EventMethod, object State)
        {
            this.when = When;
            this.eventMethod = EventMethod;
            this.state = State;
        }
 
        public ScheduledEvent(DateTime When, Func<object, Task> EventMethod, object State)
        {
            this.when = When;
            this.eventMethod = this.AsyncCallback;
            this.state = new object[] { EventMethod, State };
        }
 
        private async void AsyncCallback(object State)
        {
            try
            {
                object[] P = (object[])State;
                Func<object, Task> Callback = (Func<object, Task>)P[0];
                State = P[1];
                
                if (!(Callback is null))
                    await Callback(State);
            }
            catch (Exception ex)
            {
                Log.Exception(ex);
            }
        }
 
        public DateTime When => this.when;
 
        public Action<object> EventMethod => this.eventMethod;
 
        public object State => this.state;
 
        public void Execute()
        {
            if (!(this.eventMethod is null))
            {
                try
                {
                    this.eventMethod(this.state);
                }
                catch (Exception ex)
                {
                    Log.Exception(ex);
                }
            }
        }
 
    }
}