18 lines
503 B
C#
18 lines
503 B
C#
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;
|
|
}
|
|
}
|