channelreader_wat.linq

<Query Kind="Program">
  <Namespace>System.Threading.Channels</Namespace>
  <Namespace>System.Threading.Tasks</Namespace>
</Query>

async Task Main()
{
	var channel = Channel.CreateBounded<string>(100);
	
	Func<CancellationTokenSource> newCts = ()=> new CancellationTokenSource();
	var cts1 = newCts();
	var cts2 = newCts();
	var cts3 = newCts();
	var cts4 = newCts();
	
	try
	{
		var r = channel.Reader.WaitToReadAsync(cts1.Token);
		cts1.Cancel();
		await r;
	}
	catch
	{
		
	}
	try
	{
	var r = channel.Reader.WaitToReadAsync(cts2.Token);
		cts2.Cancel();
		await r;
	}
	catch
	{

	}
	try
	{
	var r = channel.Reader.WaitToReadAsync(cts3.Token);
		cts3.Cancel();
		await r;
	}
	catch
	{

	}
	try
	{
	var r = channel.Reader.WaitToReadAsync(cts4.Token);
		cts4.Cancel();
		await r;
	}
	catch
	{

	}

	Debugger.Break(); //Check the channel's private _waitingReadersTail here
	channel.Writer.TryWrite("willClear");
	Debugger.Break(); //Now it's cleared out.
	await channel.Reader.WaitToReadAsync();
	Debugger.Break();
}