InMemoryProducerDataProvider for Audit.NET

InMemoryProducerDataProvider.cs

public class InMemoryProducerDataProvider : AuditDataProvider
{
    private readonly BlockingCollection<AuditEvent> _events;
    
    public int Count => _events.Count;

    public InMemoryProducerDataProvider()
    {
		_events = new BlockingCollection<AuditEvent>();
    }

    public override object InsertEvent(AuditEvent auditEvent)
    {
        _events.Add(auditEvent);
        return null;
    }

    public override Task<object> InsertEventAsync(AuditEvent auditEvent, CancellationToken cancellationToken = default)
    {
        _events.Add(auditEvent, cancellationToken);
        return Task.FromResult<object>(null);
    }

    public override void ReplaceEvent(object eventId, AuditEvent auditEvent)
    {
        throw new NotImplementedException(ReplaceEventErrorString);
    }

    public override Task ReplaceEventAsync(object eventId, AuditEvent auditEvent, CancellationToken cancellationToken = default)
    {
        throw new NotImplementedException(ReplaceEventErrorString);
    }

    public AuditEvent Take(CancellationToken cancellationToken = default)
    {
        return _events.Take(cancellationToken);
    }
}