OffsetProcessor.cs

using System.Threading.Tasks;
using Waher.Persistence;
 
namespace Waher.Script.Persistence.SQL.Processors
{
    public class OffsetProcessor : IProcessor<object>
    {
        private readonly IProcessor<object> processor;
        private readonly bool isAsynchronous;
        private int offset;
 
        public OffsetProcessor(IProcessor<object> Processor, int Offset)
        {
            this.processor = Processor;
            this.offset = Offset;
            this.isAsynchronous = Processor.IsAsynchronous;
        }
 
        public bool IsAsynchronous => this.isAsynchronous;
 
        public bool Process(object Object)
        {
            if (this.offset > 0)
            {
                this.offset--;
                return true;
            }
            else
                return this.processor.Process(Object);
        }
 
        public Task<bool> ProcessAsync(object Object)
        {
            if (this.offset > 0)
            {
                this.offset--;
                return Task.FromResult(true);
            }
            else
                return this.processor.ProcessAsync(Object);
        }
 
        public bool Flush() => this.processor.Flush();
 
        public Task<bool> FlushAsync() => this.processor.FlushAsync();
    }
}