1 write to _channel
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
33
_channel
= Channel.CreateUnbounded<ParallelizableTestModuleGroupWithSequentialInnerModules>(new UnboundedChannelOptions { SingleReader = false, SingleWriter = false });
3 references to _channel
dotnet (3)
Commands\Test\MTP\TestApplicationActionQueue.cs (3)
58
if (!
_channel
.Writer.TryWrite(testApplication))
67
_channel
.Writer.Complete();
88
await foreach (var nonParallelizedGroup in
_channel
.Reader.ReadAllAsync(_cancellationToken))