IAsyncProcessor.cs

using System.Threading.Tasks;
using Waher.Events;
 
namespace Waher.Runtime.Queue
{
    public interface IAsyncProcessor : IDisposableAsync
    {
        void CloseForTermination();
 
        Task CloseForTermination(bool WaitForCompletion);
 
        Task CloseForTermination(bool WaitForCompletion, int Timeout);
 
        string Name { get; }
 
        bool Terminating { get; }
 
        bool Terminated { get; }
 
        int QueueSize { get; }
 
        bool Idle { get; }
 
        event EventHandlerAsync<ProcessorEventArgs> OnIdle;
 
        Task WaitUntilIdle();
    }
}