PredicateAsyncProcessor.cs

using System.Threading.Tasks;
using Waher.Runtime.Collections;
 
namespace Waher.Persistence.Processors
{
    public class PredicateAsyncProcessor<T> : IProcessor<T>
    {
        private readonly PredicateAsync<T> callback;
 
        public PredicateAsyncProcessor(PredicateAsync<T> Callback)
        {
            this.callback = Callback;
        }
 
        public bool IsAsynchronous => true;
 
        public bool Process(T Object) => this.callback(Object).Result;
 
        public Task<bool> ProcessAsync(T Object) => this.callback(Object);
 
        public bool Flush()
        {
            return true;
        }
 
        public Task<bool> FlushAsync()
        {
            return Task.FromResult(true);
        }
    }
}