using OpenAuth.Repository.Domain;
using System.Threading.Channels;

namespace OpenAuth.WebApi.Model.mqtt.ChannelDB
{
    public class LogQueueService
    {
        private readonly Channel<LasaLog> _channel = Channel.CreateBounded<LasaLog>(
        new BoundedChannelOptions(10000)
        {
            FullMode = BoundedChannelFullMode.DropOldest
        });

        public ChannelWriter<LasaLog> Writer => _channel.Writer;
        public ChannelReader<LasaLog> Reader => _channel.Reader;
    }
}