ChannelService.cs

ChannelService.cs

    public class ChannelService<TMessage> where TMessage : class, new()
    {
        private readonly Channel<TMessage> _serviceChannel;

        public ChannelService()
        {
            _serviceChannel = Channel.CreateBounded<TMessage>(new BoundedChannelOptions(5000)
            {
                SingleReader = false,
                SingleWriter = false,
                FullMode = BoundedChannelFullMode.DropWrite
            });
        }

        public async Task Add(TMessage model, CancellationToken cancellationToken)
        {
            await _serviceChannel.Writer.WriteAsync(model, cancellationToken);
        }

        public IAsyncEnumerable<TMessage> Get(CancellationToken cancellationToken)
        {
            return _serviceChannel.Reader.ReadAllAsync(cancellationToken);
        }
    }