python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
ChannelReader.ReadAsync(CancellationToken) and ChannelWriter.WriteAsync(CancellationToken) don't return or throw when token is signaled
EDIT: I'm cleaning up the description because I've since determined this also impacts WriteAsync, not just ReadAsync...
If one of these calls is currently blocking - ReadAsync because the channel is e...
Jeff
Votes: 0
Answers: 1
Channel Writer requiring Task.Delay and not processing all messages
I am adding messages to a threading channel and reading from this channel constantly. I noticed that if I do not add a Task.Delay then all of the messages are not processed. The program will exit with...
Terrance Jackson
Votes: 0
Answers: 1
Consume all messages in a System.Threading.Channels.Channel
Suppose I have a many producers, 1 consumer unbound Channel, with a consumer:
await foreach (var message in channel.Reader.ReadAllAsync(cts.Token))
{
await consume(message);
}
The problem is that...
Guiorgy
Votes: 0
Answers: 2
Async method not executing when using System.Threading.Channels
For some reason, it appears code inside of the Consumer nor Producer Tasks is ever executed. Where am I going wrong?
using System.Threading.Channels;
namespace TEST.CHANNELS
{
public class Progra...
LCaraway
Votes: 0
Answers: 2