CommandStatusBase.cs

using System;
using System.Net;
using System.Threading.Tasks;
 
namespace Waher.Networking.Cluster
{
    internal abstract class CommandStatusBase
    {
        public Guid Id;
        public IClusterCommand Command;
        public byte[] CommandBinary;
        public DateTime Timeout;
        public DateTime TimeLimit;
        public object State;
 
        public abstract bool IsComplete(EndpointStatus[] Statuses);
 
        public abstract void AddResponse(IPEndPoint From, object Response);
 
        public abstract Task RaiseResponseEvent(EndpointStatus[] CurrentStatus);
 
        public abstract void AddError(IPEndPoint From, Exception Error);
    }
}