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