BlockingCollection

25 references to BlockingCollection

Aspire.RabbitMQ.Client.Tests (1)

AspireRabbitMQLoggingTests.cs (1)

203public BlockingCollection<(LogLevel Level, string Message, object? State)> Logs { get; } = new();

InteropTests (1)

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Microsoft.AspNetCore.Server.IntegrationTesting (1)

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Microsoft.AspNetCore.Shared.Tests (1)

SingleThreadedSynchronizationContext.cs (1)

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

Microsoft.Build (2)

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (1)

579private BlockingCollection<INodePacket> _packetWriteQueue = new BlockingCollection<INodePacket>();

BackEnd\Components\RequestBuilder\RequestBuilder.cs (1)

1445private readonly BlockingCollection<Task> _tasks = new BlockingCollection<Task>();

Microsoft.CodeAnalysis.CSharp.Scripting.UnitTests (1)

ObjectFormatterTests.cs (1)

723var obj = new BlockingCollection<int>();

Microsoft.DotNet.Open.Api.Tools.Tests (1)

ProcessEx.cs (1)

22private BlockingCollection<string> _stdoutLines = new BlockingCollection<string>();

Microsoft.Extensions.ApiDescription.Client.Tests (1)

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Microsoft.Extensions.Diagnostics.HealthChecks.Tests (1)

src\Shared\test\Shared.Tests\SingleThreadedSynchronizationContext.cs (1)

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

Microsoft.Extensions.Http.Polly.Tests (1)

src\Shared\test\Shared.Tests\SingleThreadedSynchronizationContext.cs (1)

14private readonly BlockingCollection<(SendOrPostCallback Callback, object? State)> _queue = new BlockingCollection<(SendOrPostCallback Callback, object? State)>();

Microsoft.Maui.Graphics.Win2D.WinUI.Desktop (1)

src\Graphics\src\Graphics\Platforms\Windows\AsyncPump.cs (1)

92 new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();

Microsoft.ML.Core.Tests (2)

UnitTests\TestHosts.cs (2)

32var hosts = new BlockingCollection<Tuple<IHost, int>>(); 95var hosts = new BlockingCollection<Tuple<IHost, int>>();

ScenarioTests.Common.Tests (1)

ScenarioTestTypes.cs (1)

179new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();

Templates.Blazor.Tests (1)

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Templates.Blazor.WebAssembly.Auth.Tests (2)

src\Shared\E2ETesting\SauceConnectServer.cs (1)

124var logOutput = new BlockingCollection<string>();

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Templates.Blazor.WebAssembly.Tests (2)

src\Shared\E2ETesting\SauceConnectServer.cs (1)

124var logOutput = new BlockingCollection<string>();

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Templates.Mvc.Tests (2)

src\Shared\E2ETesting\SauceConnectServer.cs (1)

124var logOutput = new BlockingCollection<string>();

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

Templates.Tests (2)

src\Shared\E2ETesting\SauceConnectServer.cs (1)

124var logOutput = new BlockingCollection<string>();

src\Shared\Process\ProcessEx.cs (1)

41_stdoutLines = new BlockingCollection<string>();

UnitTests.Common (1)

TestTypes.cs (1)

269new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();