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