Channel Async Streaming

In the example (shown below), the _ChannelClosedException_ is caught when the channel is closed.
This is not an exception, but the rule.  
Instead, the channel reader can also be used in combination with [async streaming](https://learn.microsoft.com/en-us/dotnet/api/system.threading.channels.channelreader-1.readallasync?view=net-7.0#system-threading-channels-channelreader-1-readallasync(system-threading-cancellationtoken)).

https://github.com/ProfessionalCSharp/ProfessionalCSharp2021/blob/5b29a81a47683cb0ade58554260552bf0bd9d634/2_Libs/Parallel/ParallelSamples/ChannelSample/ChannelSample.cs#L26-L44

	public static Task ReadSomeDataAsync(ChannelReader<SomeData> reader) =>
	Task.Run(async () =>
	{
	try
	{
	Console.WriteLine("Start reading...");
	Random r = new();
	while (true)
	{
	await Task.Delay(r.Next(80));
	var data = await reader.ReadAsync();
	Console.WriteLine($"read: {data.Text}, available items: {reader.Count}");
	}
	}
	catch (ChannelClosedException)
	{
	Console.WriteLine("channel closed");
	}
	});

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Channel Async Streaming #200

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Channel Async Streaming #200

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions