channels.cs

using System.Threading.Channels;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddLogging();
builder.Services.AddSingleton<Channel<Ping>>(x => Channel.CreateUnbounded<Ping>(new UnboundedChannelOptions { SingleReader = true }));
builder.Services.AddHostedService<Consumer>();

builder.WebHost.UseUrls("http://localhost:5050");
builder.Logging.AddConsole();

var app = builder.Build();

app.MapGet("/test", async (Channel<Ping> channel) =>
{
    await channel.Writer.WriteAsync(new Ping("CodeOpinion"));
    return "OK";
});

await app.RunAsync();


public record Ping(string Message);

public class Consumer : IHostedService
{
    private readonly Channel<Ping> _channel;

    public Consumer(Channel<Ping> channel)
    {
        _channel = channel;
    }
    
    public async Task StartAsync(CancellationToken cancellationToken)
    {
        while (await _channel.Reader.WaitToReadAsync(cancellationToken))
        {
            var item = await _channel.Reader.ReadAsync(cancellationToken);
            Console.WriteLine($"Consumed: {item.Message}");
        }
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        return Task.CompletedTask;
    }
}