Questions about system.threading.channels
Read more about system.threading.channels
python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
Is SemaphoreSlim needed when Channel's SingleReader is set to true
When sending data fast enough, InvalidOperationException is being thrown: 'There is already one outstanding 'SendAsync' call for this WebSocket instance. ClientWebSocket.ReceiveAsync and ClientWebSock...
nop
Votes: 0
Answers: 2
How to not propagate Activity in Task.Factory.StartNew
I have the following code:
Task task = null;
var channel = System.Threading.Channels.Channel.CreateUnbounded<string>();
using (var activity = MyActivitySource.StartActivity("Parent"))...
Sierrodc
Votes: 0
Answers: 1
How does a channel consumer get everything from multiple channel producers when any producer can close the entire channel at any time?
I'm new to System.Threading.Channels. I have the following consumer code:
await foreach (var thing in this.Reader.ReadAllAsync(cancellationToken)
.ConfigureAwait(false))
{
await this.HandleThi...
Bob Vesterman
Votes: 0
Answers: 2
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