Worker ExecuteAsync with IEventProcessor

worker-execute-async.cs

public class Worker : BackgroundService
{
    private readonly IEventProcessor _eventProcessor;
    private readonly ILogger<Worker> _logger;

    public Worker(IEventProcessor eventProcessor, ILogger<Worker> logger)
    {
        _eventProcessor = eventProcessor;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
            await _eventProcessor.Process(stoppingToken);
        }
    }
}